connections: add redis_url alias to _get_aredis_connection and update AsyncSearchIndex callers; tests: fix schema prefix typo

Author: abrookins

redisvl/index/index.py

@@ -1195,7 +1195,7 @@ async def from_existing(
 
         if redis_url:
             redis_client = await RedisConnectionFactory._get_aredis_connection(
-                url=redis_url,
+                redis_url=redis_url,
                 **kwargs,
             )
         elif redis_client:
@@ -1229,7 +1229,7 @@ async def connect(self, redis_url: Optional[str] = None, **kwargs):
             DeprecationWarning,
         )
         client = await RedisConnectionFactory._get_aredis_connection(
-            url=redis_url, **kwargs
+            redis_url=redis_url, **kwargs
         )
         await self.set_client(client)
 
@@ -1254,7 +1254,7 @@ async def _get_client(self) -> AsyncRedisClient:
                     # Pass lib_name to connection factory
                     kwargs = {**self._connection_kwargs}
                     if self._redis_url:
-                        kwargs["url"] = self._redis_url
+                        kwargs["redis_url"] = self._redis_url
                     if self._lib_name:
                         kwargs["lib_name"] = self._lib_name
                     self._redis_client = (

redisvl/redis/connection.py

@@ -386,6 +386,7 @@ def get_redis_connection(
     @staticmethod
     async def _get_aredis_connection(
         url: Optional[str] = None,
+        redis_url: Optional[str] = None,
         **kwargs,
     ) -> AsyncRedisClient:
         """Creates and returns an asynchronous Redis client.
@@ -394,8 +395,9 @@ async def _get_aredis_connection(
         only used internally by the library now.
 
         Args:
-            url (Optional[str]): The URL of the Redis server. If not provided,
-                the environment variable REDIS_URL is used.
+            url (Optional[str]): The URL of the Redis server.
+            redis_url (Optional[str]): Alias for url for consistency with public APIs.
+                If neither is provided, the environment variable REDIS_URL is used.
             **kwargs: Additional keyword arguments to be passed to the async
                 Redis client constructor.
 
@@ -406,7 +408,7 @@ async def _get_aredis_connection(
             ValueError: If url is not provided and REDIS_URL environment
                 variable is not set.
         """
-        url = url or get_address_from_env()
+        url = url or redis_url or get_address_from_env()
 
         client: AsyncRedisClient
         if url.startswith("redis+sentinel"):

tests/unit/test_schema.py

@@ -252,7 +252,7 @@ def test_schema_serialization_with_new_attributes():
     original_schema_dict = {
         "index": {
             "name": "test-serialization",
-            "prefix": "ser",
+            "prefix": "set",
             "storage_type": "hash",
         },
         "fields": [