feat(client-info)!: add full library version info to Redis client tracking

- Add client_setinfo calls in RedisSaver.configure_client() to register library version with Redis
- Update all set_client_info/aset_client_info methods to use __full_lib_name__ instead of __redisvl_version__
- Ensure graceful error handling with fallback to echo() and silent failure
- Remove redundant test_jsonplus_redis_serializer.py from root directory
- Update all client info tests to expect full library name format
- Add client_setinfo/echo mock methods to BaseMockRedis for cluster mode tests

BREAKING CHANGE: Client info now sends complete version string format:
redis-py(redisvl_v{version};langgraph-checkpoint-redis_v{version})

This provides better visibility in Redis CLIENT LIST for monitoring and debugging,
showing redis-py client, RedisVL version, and checkpoint-redis library version.

Author: bsbodden

langgraph/checkpoint/redis/__init__.py

@@ -94,11 +94,26 @@ def configure_client(
         connection_args: Optional[Dict[str, Any]] = None,
     ) -> None:
         """Configure the Redis client."""
+        from redis.exceptions import ResponseError
+
+        from langgraph.checkpoint.redis.version import __full_lib_name__
+
         self._owns_its_client = redis_client is None
         self._redis = redis_client or RedisConnectionFactory.get_redis_connection(
             redis_url, **connection_args
         )
 
+        # Set client info for Redis monitoring
+        try:
+            self._redis.client_setinfo("LIB-NAME", __full_lib_name__)
+        except (ResponseError, AttributeError):
+            # Fall back to a simple echo if client_setinfo is not available
+            try:
+                self._redis.echo(__full_lib_name__)
+            except Exception:
+                # Silently fail if even echo doesn't work
+                pass
+
     def create_indexes(self) -> None:
         self.checkpoints_index = SearchIndex.from_dict(
             self.SCHEMAS[0], redis_client=self._redis

langgraph/checkpoint/redis/base.py

@@ -175,19 +175,16 @@ 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 __redisvl_version__
-
-        # Create the client info string with only the redisvl version
-        client_info = f"redis-py(redisvl_v{__redisvl_version__})"
+        from langgraph.checkpoint.redis.version import __full_lib_name__
 
         try:
             # Try to use client_setinfo command if available
-            await self._redis.client_setinfo("LIB-NAME", client_info)
+            await self._redis.client_setinfo("LIB-NAME", __full_lib_name__)
         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(client_info)
+                echo_result = self._redis.echo(__full_lib_name__)
                 if hasattr(echo_result, "__await__"):
                     await echo_result
             except Exception:

langgraph/store/redis/base.py

@@ -325,38 +325,32 @@ def __init__(
     def set_client_info(self) -> None:
         """Set client info for Redis monitoring."""
 
-        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__})"
+        from langgraph.checkpoint.redis.version import __full_lib_name__
 
         try:
             # Try to use client_setinfo command if available
-            self._redis.client_setinfo("LIB-NAME", client_info)
+            self._redis.client_setinfo("LIB-NAME", __full_lib_name__)
         except (ResponseError, AttributeError):
             # Fall back to a simple echo if client_setinfo is not available
             try:
-                self._redis.echo(client_info)
+                self._redis.echo(__full_lib_name__)
             except Exception:
                 # Silently fail if even echo doesn't work
                 pass
 
     async def aset_client_info(self) -> None:
         """Set client info for Redis monitoring asynchronously."""
 
-        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__})"
+        from langgraph.checkpoint.redis.version import __full_lib_name__
 
         try:
             # Try to use client_setinfo command if available
-            await self._redis.client_setinfo("LIB-NAME", client_info)
+            await self._redis.client_setinfo("LIB-NAME", __full_lib_name__)
         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(client_info)
+                echo_result = self._redis.echo(__full_lib_name__)
                 if hasattr(echo_result, "__await__"):
                     await echo_result
             except Exception:

poetry.lock

@@ -283,10 +283,7 @@ 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 __redisvl_version__
-
-    # Expected client info format
-    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
+    from langgraph.checkpoint.redis.version import __full_lib_name__
 
     # Track if client_setinfo was called with the right parameters
     client_info_called = False
@@ -297,9 +294,8 @@ async def test_async_client_info_setting(redis_url: str, monkeypatch) -> None:
     # Create a mock function for client_setinfo
     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 value == expected_client_info:
+        # Track calls with our full lib name
+        if key == "LIB-NAME" and value == __full_lib_name__:
             client_info_called = True
         # Call original method to ensure normal function
         return await original_client_setinfo(self, key, value)

test_jsonplus_redis_serializer.py

@@ -544,10 +544,7 @@ 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 __redisvl_version__
-
-    # Expected client info format
-    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
+    from langgraph.checkpoint.redis.version import __full_lib_name__
 
     # Track if client_setinfo was called with the right parameters
     client_info_called = False
@@ -558,9 +555,8 @@ async def test_async_redis_store_client_info(redis_url: str, monkeypatch) -> Non
     # Create a mock function for client_setinfo
     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 value == expected_client_info:
+        # Track calls with our full lib name
+        if key == "LIB-NAME" and value == __full_lib_name__:
             client_info_called = True
         # Call original method to ensure normal function
         return await original_client_setinfo(self, key, value)
@@ -584,10 +580,7 @@ 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 __redisvl_version__
-
-    # Expected client info format
-    expected_client_info = f"redis-py(redisvl_v{__redisvl_version__})"
+    from langgraph.checkpoint.redis.version import __full_lib_name__
 
     # Remove client_setinfo to simulate older Redis version
     async def mock_client_setinfo(self, key, value):
@@ -601,7 +594,7 @@ async def mock_client_setinfo(self, key, value):
     async def mock_echo(self, message):
         nonlocal echo_called
         echo_called = True
-        assert message == expected_client_info
+        assert message == __full_lib_name__
         return await original_echo(self, message)
 
     # Apply the mocks

tests/test_async.py

@@ -90,12 +90,10 @@ async def test_aset_client_info_success():
     # Mock async client_setinfo
     saver._redis.client_setinfo = AsyncMock()
 
-    with patch("langgraph.checkpoint.redis.version.__redisvl_version__", "1.2.3"):
+    with patch("langgraph.checkpoint.redis.version.__full_lib_name__", "test-lib-v1.0"):
         await saver.aset_client_info()
 
-    saver._redis.client_setinfo.assert_called_once_with(
-        "LIB-NAME", "redis-py(redisvl_v1.2.3)"
-    )
+    saver._redis.client_setinfo.assert_called_once_with("LIB-NAME", "test-lib-v1.0")
 
 
 @pytest.mark.asyncio
@@ -112,7 +110,7 @@ async def mock_echo(msg):
 
     saver._redis.echo = mock_echo
 
-    with patch("langgraph.checkpoint.redis.version.__redisvl_version__", "1.2.3"):
+    with patch("langgraph.checkpoint.redis.version.__full_lib_name__", "test-lib-v1.0"):
         await saver.aset_client_info()
 
     saver._redis.client_setinfo.assert_called_once()

tests/test_async_store.py

@@ -92,6 +92,14 @@ def cluster(self, subcmd: str, *args, **kwargs):
             raise ResponseError("ERR This instance has cluster support disabled")
         return {}
 
+    def client_setinfo(self, key, value):
+        """Mock client_setinfo for testing."""
+        return "OK"
+
+    def echo(self, message):
+        """Mock echo for testing."""
+        return message
+
 
 class MockRedis(BaseMockRedis, Redis):
     pass