Skip to content

Commit 8c97668

Browse files
authored
fix url vs redis_url (#289)
There was a bug in from_existing where it was not passing the redis_url correctly because the var is named `url` ![image](https://github.com/user-attachments/assets/f350264f-debb-4382-ad40-be38a3609cb3)
1 parent db17aef commit 8c97668

File tree

5 files changed

+17
-6
lines changed

5 files changed

+17
-6
lines changed

redisvl/cli/index.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ def listall(self, args: Namespace):
7979
rvl index listall
8080
"""
8181
redis_url = create_redis_url(args)
82-
conn = RedisConnectionFactory.get_redis_connection(redis_url)
82+
conn = RedisConnectionFactory.get_redis_connection(redis_url=redis_url)
8383
indices = convert_bytes(conn.execute_command("FT._LIST"))
8484
logger.info("Indices:")
8585
for i, index in enumerate(indices):
@@ -107,7 +107,7 @@ def _connect_to_index(self, args: Namespace) -> SearchIndex:
107107
# connect to redis
108108
try:
109109
redis_url = create_redis_url(args)
110-
conn = RedisConnectionFactory.get_redis_connection(url=redis_url)
110+
conn = RedisConnectionFactory.get_redis_connection(redis_url=redis_url)
111111
except ValueError:
112112
logger.error(
113113
"Must set REDIS_URL environment variable or provide host and port"

redisvl/index/index.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -358,7 +358,7 @@ def _redis_client(self) -> Optional[redis.Redis]:
358358
with self._lock:
359359
if self.__redis_client is None:
360360
self.__redis_client = RedisConnectionFactory.get_redis_connection(
361-
url=self._redis_url,
361+
redis_url=self._redis_url,
362362
**self._connection_kwargs,
363363
)
364364
return self.__redis_client

redisvl/redis/connection.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,7 @@ def connect(
223223

224224
@staticmethod
225225
def get_redis_connection(
226-
url: Optional[str] = None,
226+
redis_url: Optional[str] = None,
227227
required_modules: Optional[List[Dict[str, Any]]] = None,
228228
**kwargs,
229229
) -> Redis:
@@ -245,7 +245,7 @@ def get_redis_connection(
245245
variable is not set.
246246
RedisModuleVersionError: If required Redis modules are not installed.
247247
"""
248-
url = url or get_address_from_env()
248+
url = redis_url or get_address_from_env()
249249
client = Redis.from_url(url, **kwargs)
250250

251251
RedisConnectionFactory.validate_sync_redis(

tests/conftest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ def client(redis_url):
6363
"""
6464
A sync Redis client that uses the dynamic `redis_url`.
6565
"""
66-
conn = RedisConnectionFactory.get_redis_connection(redis_url)
66+
conn = RedisConnectionFactory.get_redis_connection(redis_url=redis_url)
6767
yield conn
6868

6969

tests/integration/test_search_index.py

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,17 @@ def test_search_index_from_existing(client, index):
8484
assert index2.schema == index.schema
8585

8686

87+
def test_search_index_from_existing_url(redis_url, index):
88+
index.create(overwrite=True)
89+
90+
try:
91+
index2 = SearchIndex.from_existing(index.name, redis_url=redis_url)
92+
except Exception as e:
93+
pytest.skip(str(e))
94+
95+
assert index2.schema == index.schema
96+
97+
8798
def test_search_index_from_existing_complex(client):
8899
schema = {
89100
"index": {

0 commit comments

Comments
 (0)