From 4506fa952b9311dc77b18a244905308e71528eb6 Mon Sep 17 00:00:00 2001 From: Ishaan Jaff Date: Fri, 11 Oct 2024 23:55:14 +0530 Subject: [PATCH] fix redis sentinel - use sentinel password --- litellm/_redis.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/litellm/_redis.py b/litellm/_redis.py index 4a750a314..e58d14ebc 100644 --- a/litellm/_redis.py +++ b/litellm/_redis.py @@ -225,10 +225,6 @@ def _init_async_redis_sentinel(redis_kwargs) -> async_redis.Redis: sentinel_password = redis_kwargs.get("sentinel_password") service_name = redis_kwargs.get("service_name") - sentinel_kwargs: Optional[Dict] = None - if sentinel_password: - sentinel_kwargs = {"password": sentinel_password} - if not sentinel_nodes or not service_name: raise ValueError( "Both 'sentinel_nodes' and 'service_name' are required for Redis Sentinel." @@ -238,7 +234,9 @@ def _init_async_redis_sentinel(redis_kwargs) -> async_redis.Redis: # Set up the Sentinel client sentinel = async_redis.Sentinel( - sentinel_nodes, socket_timeout=0.1, sentinel_kwargs=sentinel_kwargs + sentinel_nodes, + socket_timeout=0.1, + password=sentinel_password, ) # Return the master instance for the given service