The *AI-native* Redis Python client
diff --git a/pyproject.toml b/pyproject.toml
index 8593c62a..64b4cda9 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1,6 +1,6 @@
[tool.poetry]
name = "redisvl"
-version = "0.4.0"
+version = "0.4.1"
description = "Python client library and CLI for using Redis as a vector database"
authors = ["Redis Inc.
"]
license = "MIT"
diff --git a/redisvl/version.py b/redisvl/version.py
index 6a9beea8..3d26edf7 100644
--- a/redisvl/version.py
+++ b/redisvl/version.py
@@ -1 +1 @@
-__version__ = "0.4.0"
+__version__ = "0.4.1"
diff --git a/tests/integration/test_async_search_index.py b/tests/integration/test_async_search_index.py
index 2aa7ae0f..2dd97e36 100644
--- a/tests/integration/test_async_search_index.py
+++ b/tests/integration/test_async_search_index.py
@@ -80,6 +80,20 @@ async def test_search_index_from_existing(async_client, async_index):
assert async_index2.schema == async_index.schema
+@pytest.mark.asyncio
+async def test_search_index_from_existing_url(async_index, redis_url):
+ await async_index.create(overwrite=True)
+
+ try:
+ async_index2 = await AsyncSearchIndex.from_existing(
+ async_index.name, redis_url=redis_url
+ )
+ except Exception as e:
+ pytest.skip(str(e))
+
+ assert async_index2.schema == async_index.schema
+
+
@pytest.mark.asyncio
async def test_search_index_from_existing_complex(async_client):
schema = {
diff --git a/tests/integration/test_search_index.py b/tests/integration/test_search_index.py
index 4b5ef7ff..fab4a591 100644
--- a/tests/integration/test_search_index.py
+++ b/tests/integration/test_search_index.py
@@ -73,7 +73,7 @@ def test_search_index_from_dict(index_from_dict):
assert index_from_dict.key("foo").startswith(index_from_dict.prefix)
-def test_search_index_from_existing(client, index):
+def test_search_index_from_existing(index, client):
index.create(overwrite=True)
try:
@@ -176,6 +176,13 @@ def test_search_index_set_client(async_client, redis_url, index_schema):
assert index.client is None
+def test_search_index_connect(index, redis_url):
+ with warnings.catch_warnings():
+ warnings.filterwarnings("ignore", category=DeprecationWarning)
+ index.connect(redis_url=redis_url)
+ assert index.client
+
+
def test_search_index_create(index):
index.create(overwrite=True, drop=True)
assert index.exists()