Update app/memory/redis_checkpointer.py

app/memory/redis_checkpointer.py

@@ -1,5 +1,5 @@
 from __future__ import annotations
-from redis.exceptions import ConnectionError as RedisConnectionError, TimeoutError as RedisTimeoutError
+
 from langgraph.checkpoint.redis.aio import AsyncRedisSaver
 
 from app.config import get_settings
@@ -9,6 +9,7 @@ _checkpointer: AsyncRedisSaver | None = None
 
 
 async def get_checkpointer() -> AsyncRedisSaver:
+
     global _checkpointer_cm, _checkpointer
     if _checkpointer is None:
         settings = get_settings()
@@ -16,12 +17,6 @@ async def get_checkpointer() -> AsyncRedisSaver:
 
         _checkpointer_cm = AsyncRedisSaver.from_conn_string(
             settings.redis_url,
-            connection_args={
-                "health_check_interval": 30,
-                "socket_keepalive": True,
-                "retry_on_timeout": True,
-                "retry_on_error": [ConnectionError, TimeoutError],
-            },
             ttl={"default_ttl": ttl_minutes, "refresh_on_read": True},
         )
         _checkpointer = await _checkpointer_cm.__aenter__()
@@ -34,4 +29,4 @@ async def close_checkpointer() -> None:
     if _checkpointer_cm is not None:
         await _checkpointer_cm.__aexit__(None, None, None)
     _checkpointer = None
-    _checkpointer_cm = None
+    _checkpointer_cm = None