fix: #2081 Redis SSL Connection Error with redis-py v7 (#2082)

Author: yju0808

pyproject.toml

@@ -41,7 +41,7 @@ litellm = ["litellm>=1.67.4.post1, <2"]
 realtime = ["websockets>=15.0, <16"]
 sqlalchemy = ["SQLAlchemy>=2.0", "asyncpg>=0.29.0"]
 encrypt = ["cryptography>=45.0, <46"]
-redis = ["redis>=6.4.0"]
+redis = ["redis>=7"]
 dapr = ["dapr>=1.16.0", "grpcio>=1.60.0"]
 
 [dependency-groups]

src/agents/extensions/memory/redis_session.py

@@ -25,7 +25,6 @@
 import json
 import time
 from typing import Any
-from urllib.parse import urlparse
 
 try:
     import redis.asyncio as redis
@@ -96,11 +95,6 @@ def from_url(
         """
         redis_kwargs = redis_kwargs or {}
 
-        # Parse URL to determine if we need SSL
-        parsed = urlparse(url)
-        if parsed.scheme == "rediss":
-            redis_kwargs.setdefault("ssl", True)
-
         redis_client = redis.from_url(url, **redis_kwargs)
         session = cls(session_id, redis_client=redis_client, **kwargs)
         session._owns_client = True  # We created the client, so we own it
@@ -261,7 +255,7 @@ async def ping(self) -> bool:
             True if Redis is reachable, False otherwise.
         """
         try:
-            await self._redis.ping()
+            await self._redis.ping()  # type: ignore[misc]  # Redis library returns Union[Awaitable[T], T] in async context
             return True
         except Exception:
             return False

tests/extensions/memory/test_redis_session.py

@@ -492,14 +492,14 @@ async def test_external_client_not_closed():
         assert len(items) == 1
 
         # Verify client is working before close
-        assert await shared_client.ping() is True
+        assert await shared_client.ping() is True  # type: ignore[misc]  # Redis library returns Union[Awaitable[T], T] in async context
 
         # Close the session
         await session.close()
 
         # Verify the shared client is still usable after session.close()
         # This would fail if we incorrectly closed the external client
-        assert await shared_client.ping() is True
+        assert await shared_client.ping() is True  # type: ignore[misc]  # Redis library returns Union[Awaitable[T], T] in async context
 
         # Should still be able to use the client for other operations
         await shared_client.set("test_key", "test_value")
@@ -781,7 +781,7 @@ async def test_close_method_coverage():
     await session1.close()
 
     # Verify external client is still usable
-    assert await external_client.ping() is True
+    assert await external_client.ping() is True  # type: ignore[misc]  # Redis library returns Union[Awaitable[T], T] in async context
 
     # Test 2: Internal client (should be closed)
     # Create a session that owns its client