Skip to content

Commit 4fa7350

Browse files
support connection args on async redis store
1 parent e99a561 commit 4fa7350

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

langgraph/store/redis/aio.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@ def __init__(
6565
*,
6666
redis_client: Optional[AsyncRedis] = None,
6767
index: Optional[IndexConfig] = None,
68+
connection_args: Optional[dict[str, Any]] = None,
6869
) -> None:
6970
"""Initialize store with Redis connection and optional index config."""
7071
if redis_url is None and redis_client is None:
@@ -94,7 +95,11 @@ def __init__(
9495
]
9596

9697
# Configure client
97-
self.configure_client(redis_url=redis_url, redis_client=redis_client)
98+
self.configure_client(
99+
redis_url=redis_url,
100+
redis_client=redis_client,
101+
connection_args=connection_args or {}
102+
)
98103

99104
# Create store index
100105
self.store_index = AsyncSearchIndex.from_dict(
@@ -149,11 +154,12 @@ def configure_client(
149154
self,
150155
redis_url: Optional[str] = None,
151156
redis_client: Optional[AsyncRedis] = None,
157+
connection_args: Optional[dict[str, Any]] = None,
152158
) -> None:
153159
"""Configure the Redis client."""
154160
self._owns_its_client = redis_client is None
155161
self._redis = redis_client or RedisConnectionFactory.get_async_redis_connection(
156-
redis_url
162+
redis_url, **connection_args
157163
)
158164

159165
async def setup(self) -> None:

0 commit comments

Comments
 (0)