We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 54b30b8 commit ad2e957Copy full SHA for ad2e957
src/common/connection.py
@@ -16,10 +16,8 @@ class RedisConnectionManager:
16
def get_connection(cls, decode_responses=True) -> Redis:
17
if cls._instance is None:
18
try:
19
- # Select the appropriate Redis client class
20
- redis_class: Type[Union[Redis, RedisCluster]] = RedisCluster if REDIS_CFG["cluster_mode"] else redis.Redis
+ redis_class: Type[Union[Redis, RedisCluster]] = redis.cluster.RedisCluster if REDIS_CFG["cluster_mode"] else redis.Redis
21
22
- # Create the connection with appropriate parameters
23
cls._instance = redis_class(
24
host=REDIS_CFG["host"],
25
port=REDIS_CFG["port"],
0 commit comments