fix(deps): upgrade redisvl to 0.5.1 for Python 3.13 compatibility

Author: bsbodden

langgraph/checkpoint/redis/base.py

@@ -154,16 +154,19 @@ async def aset_client_info(self) -> None:
         """Set client info for Redis monitoring asynchronously."""
         from redis.exceptions import ResponseError
 
-        from langgraph.checkpoint.redis.version import __full_lib_name__
+        from langgraph.checkpoint.redis.version import __lib_name__, __redisvl_version__
+
+        # Create the client info string with only the redisvl version
+        client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
         try:
             # Try to use client_setinfo command if available
-            await self._redis.client_setinfo("LIB-NAME", __full_lib_name__)  # type: ignore
+            await self._redis.client_setinfo("LIB-NAME", client_info)  # type: ignore
         except (ResponseError, AttributeError):
             # Fall back to a simple echo if client_setinfo is not available
             try:
                 # Call with await to ensure it's an async call
-                echo_result = self._redis.echo(__full_lib_name__)
+                echo_result = self._redis.echo(client_info)
                 if hasattr(echo_result, "__await__"):
                     await echo_result
             except Exception:

langgraph/store/redis/base.py

@@ -252,15 +252,18 @@ def set_client_info(self) -> None:
         """Set client info for Redis monitoring."""
         from redis.exceptions import ResponseError
 
-        from langgraph.checkpoint.redis.version import __full_lib_name__
+        from langgraph.checkpoint.redis.version import __redisvl_version__
+
+        # Create the client info string with only the redisvl version
+        client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
         try:
             # Try to use client_setinfo command if available
-            self._redis.client_setinfo("LIB-NAME", __full_lib_name__)  # type: ignore
+            self._redis.client_setinfo("LIB-NAME", client_info)  # type: ignore
         except (ResponseError, AttributeError):
             # Fall back to a simple echo if client_setinfo is not available
             try:
-                self._redis.echo(__full_lib_name__)
+                self._redis.echo(client_info)
             except Exception:
                 # Silently fail if even echo doesn't work
                 pass
@@ -269,16 +272,19 @@ async def aset_client_info(self) -> None:
         """Set client info for Redis monitoring asynchronously."""
         from redis.exceptions import ResponseError
 
-        from langgraph.checkpoint.redis.version import __full_lib_name__
+        from langgraph.checkpoint.redis.version import __redisvl_version__
+
+        # Create the client info string with only the redisvl version
+        client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
         try:
             # Try to use client_setinfo command if available
-            await self._redis.client_setinfo("LIB-NAME", __full_lib_name__)  # type: ignore
+            await self._redis.client_setinfo("LIB-NAME", client_info)  # type: ignore
         except (ResponseError, AttributeError):
             # Fall back to a simple echo if client_setinfo is not available
             try:
                 # Call with await to ensure it's an async call
-                echo_result = self._redis.echo(__full_lib_name__)
+                echo_result = self._redis.echo(client_info)
                 if hasattr(echo_result, "__await__"):
                     await echo_result
             except Exception:

poetry.lock

@@ -20,7 +20,7 @@ packages = [{ include = "langgraph" }]
 [tool.poetry.dependencies]
 python = ">=3.9,<3.14"
 langgraph-checkpoint = "^2.0.24"
-redisvl = "^0.4.1"
+redisvl = "^0.5.1"
 redis = "^5.2.1"
 python-ulid = "^3.0.0"
 langgraph = "^0.3.0"

pyproject.toml

@@ -285,7 +285,10 @@ async def test_from_conn_string_cleanup(redis_url: str) -> None:
 @pytest.mark.asyncio
 async def test_async_client_info_setting(redis_url: str, monkeypatch) -> None:
     """Test that async client_setinfo is called with correct library information."""
-    from langgraph.checkpoint.redis.version import __full_lib_name__
+    from langgraph.checkpoint.redis.version import __redisvl_version__
+
+    # Expected client info format
+    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
     # Track if client_setinfo was called with the right parameters
     client_info_called = False
@@ -298,7 +301,7 @@ async def mock_client_setinfo(self, key, value):
         nonlocal client_info_called
         # Note: RedisVL might call this with its own lib name first
         # We only track calls with our full lib name
-        if key == "LIB-NAME" and __full_lib_name__ in value:
+        if key == "LIB-NAME" and value == expected_client_info:
             client_info_called = True
         # Call original method to ensure normal function
         return await original_client_setinfo(self, key, value)
@@ -320,7 +323,10 @@ async def test_async_client_info_fallback_to_echo(redis_url: str, monkeypatch) -
     """Test that async client_setinfo falls back to echo when not available."""
     from redis.exceptions import ResponseError
 
-    from langgraph.checkpoint.redis.version import __full_lib_name__
+    from langgraph.checkpoint.redis.version import __redisvl_version__
+
+    # Expected client info format
+    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
     # Remove client_setinfo to simulate older Redis version
     async def mock_client_setinfo(self, key, value):
@@ -334,7 +340,7 @@ async def mock_client_setinfo(self, key, value):
     async def mock_echo(self, message):
         nonlocal echo_called
         echo_called = True
-        assert message == __full_lib_name__
+        assert message == expected_client_info
         return await original_echo(self, message)
 
     # Apply the mocks
@@ -357,14 +363,25 @@ async def test_async_client_info_graceful_failure(redis_url: str, monkeypatch) -
     """Test that async client info setting fails gracefully when all methods fail."""
     from redis.exceptions import ResponseError
 
+    # Create a patch for the RedisVL validation to avoid it using echo
+    from redisvl.redis.connection import RedisConnectionFactory
+    original_validate = RedisConnectionFactory.validate_async_redis
+
+    # Create a replacement validation function that doesn't use echo
+    async def mock_validate(redis_client, lib_name=None):
+        return redis_client
+
+    # Apply the validation mock first to prevent echo from being called by RedisVL
+    monkeypatch.setattr(RedisConnectionFactory, "validate_async_redis", mock_validate)
+
     # Simulate failures for both methods
     async def mock_client_setinfo(self, key, value):
         raise ResponseError("ERR unknown command")
 
     async def mock_echo(self, message):
         raise ResponseError("ERR connection broken")
 
-    # Apply the mocks
+    # Apply the Redis mocks
     monkeypatch.setattr(Redis, "client_setinfo", mock_client_setinfo)
     monkeypatch.setattr(Redis, "echo", mock_echo)
 

tests/test_async.py

@@ -547,7 +547,10 @@ async def test_async_redis_store_client_info(redis_url: str, monkeypatch) -> Non
     """Test that AsyncRedisStore sets client info correctly."""
     from redis.asyncio import Redis
 
-    from langgraph.checkpoint.redis.version import __full_lib_name__
+    from langgraph.checkpoint.redis.version import __redisvl_version__
+
+    # Expected client info format
+    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
     # Track if client_setinfo was called with the right parameters
     client_info_called = False
@@ -560,7 +563,7 @@ async def mock_client_setinfo(self, key, value):
         nonlocal client_info_called
         # Note: RedisVL might call this with its own lib name first
         # We only track calls with our full lib name
-        if key == "LIB-NAME" and __full_lib_name__ in value:
+        if key == "LIB-NAME" and value == expected_client_info:
             client_info_called = True
         # Call original method to ensure normal function
         return await original_client_setinfo(self, key, value)
@@ -584,7 +587,10 @@ async def test_async_redis_store_client_info_fallback(
     from redis.asyncio import Redis
     from redis.exceptions import ResponseError
 
-    from langgraph.checkpoint.redis.version import __full_lib_name__
+    from langgraph.checkpoint.redis.version import __redisvl_version__
+
+    # Expected client info format
+    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
     # Remove client_setinfo to simulate older Redis version
     async def mock_client_setinfo(self, key, value):
@@ -598,7 +604,7 @@ async def mock_client_setinfo(self, key, value):
     async def mock_echo(self, message):
         nonlocal echo_called
         echo_called = True
-        assert message == __full_lib_name__
+        assert message == expected_client_info
         return await original_echo(self, message)
 
     # Apply the mocks
@@ -621,14 +627,25 @@ async def test_async_redis_store_graceful_failure(redis_url: str, monkeypatch) -
     from redis.asyncio import Redis
     from redis.exceptions import ResponseError
 
+    # Create a patch for the RedisVL validation to avoid it using echo
+    from redisvl.redis.connection import RedisConnectionFactory
+    original_validate = RedisConnectionFactory.validate_async_redis
+
+    # Create a replacement validation function that doesn't use echo
+    async def mock_validate(redis_client, lib_name=None):
+        return redis_client
+
+    # Apply the validation mock first to prevent echo from being called by RedisVL
+    monkeypatch.setattr(RedisConnectionFactory, "validate_async_redis", mock_validate)
+
     # Simulate failures for both methods
     async def mock_client_setinfo(self, key, value):
         raise ResponseError("ERR unknown command")
 
     async def mock_echo(self, message):
         raise ResponseError("ERR connection broken")
 
-    # Apply the mocks
+    # Apply the Redis mocks
     monkeypatch.setattr(Redis, "client_setinfo", mock_client_setinfo)
     monkeypatch.setattr(Redis, "echo", mock_echo)
 

tests/test_async_store.py

@@ -262,7 +262,10 @@ async def test_from_conn_string_errors(redis_url: str) -> None:
 @pytest.mark.asyncio
 async def test_async_shallow_client_info_setting(redis_url: str, monkeypatch) -> None:
     """Test that client_setinfo is called with correct library information in AsyncShallowRedisSaver."""
-    from langgraph.checkpoint.redis.version import __full_lib_name__
+    from langgraph.checkpoint.redis.version import __redisvl_version__
+
+    # Expected client info format
+    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
     # Track if client_setinfo was called with the right parameters
     client_info_called = False
@@ -275,7 +278,7 @@ async def mock_client_setinfo(self, key, value):
         nonlocal client_info_called
         # Note: RedisVL might call this with its own lib name first
         # We only track calls with our full lib name
-        if key == "LIB-NAME" and __full_lib_name__ in value:
+        if key == "LIB-NAME" and value == expected_client_info:
             client_info_called = True
         # Call original method to ensure normal function
         return await original_client_setinfo(self, key, value)
@@ -297,7 +300,10 @@ async def test_async_shallow_client_info_fallback(redis_url: str, monkeypatch) -
     from redis.asyncio import Redis
     from redis.exceptions import ResponseError
 
-    from langgraph.checkpoint.redis.version import __full_lib_name__
+    from langgraph.checkpoint.redis.version import __redisvl_version__
+
+    # Expected client info format
+    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
     # Create a Redis client directly first - this bypasses RedisVL validation
     client = Redis.from_url(redis_url)
@@ -315,7 +321,7 @@ async def mock_client_setinfo(self, key, value):
     async def mock_echo(self, message):
         nonlocal echo_called, echo_messages
         echo_messages.append(message)
-        if __full_lib_name__ in message:
+        if message == expected_client_info:
             echo_called = True
         return (
             await original_echo(self, message)

tests/test_shallow_async.py

@@ -535,7 +535,10 @@ def test_redis_store_client_info(redis_url: str, monkeypatch) -> None:
     """Test that RedisStore sets client info correctly."""
     from redis import Redis as NativeRedis
 
-    from langgraph.checkpoint.redis.version import __full_lib_name__
+    from langgraph.checkpoint.redis.version import __redisvl_version__
+
+    # Expected client info format
+    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
     # Create a direct Redis client to bypass RedisVL validation
     client = NativeRedis.from_url(redis_url)
@@ -548,7 +551,7 @@ def test_redis_store_client_info(redis_url: str, monkeypatch) -> None:
         def mock_client_setinfo(self, key, value):
             nonlocal client_info_called
             # We only track calls with our full lib name
-            if key == "LIB-NAME" and __full_lib_name__ in value:
+            if key == "LIB-NAME" and value == expected_client_info:
                 client_info_called = True
             return original_client_setinfo(self, key, value)
 
@@ -570,7 +573,10 @@ def test_redis_store_client_info_fallback(redis_url: str, monkeypatch) -> None:
     """Test that RedisStore falls back to echo when client_setinfo is not available."""
     from redis import Redis as NativeRedis
 
-    from langgraph.checkpoint.redis.version import __full_lib_name__
+    from langgraph.checkpoint.redis.version import __redisvl_version__
+
+    # Expected client info format
+    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
 
     # Create a direct Redis client to bypass RedisVL validation
     client = NativeRedis.from_url(redis_url)
@@ -587,7 +593,7 @@ def mock_client_setinfo(self, key, value):
         def mock_echo(self, message):
             nonlocal echo_called
             # We only want to track our library's echo calls
-            if __full_lib_name__ in message:
+            if message == expected_client_info:
                 echo_called = True
             return original_echo(self, message)