From 0dfdd71467b5a89968682f3d1a42f361bfb2ec15 Mon Sep 17 00:00:00 2001 From: Bowen Liang Date: Sun, 11 May 2025 00:13:14 +0800 Subject: [PATCH] apply to sentinel and cluster mode --- api/extensions/ext_redis.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/api/extensions/ext_redis.py b/api/extensions/ext_redis.py index ebf8597fbe..a13d717716 100644 --- a/api/extensions/ext_redis.py +++ b/api/extensions/ext_redis.py @@ -60,6 +60,7 @@ def init_app(app: DifyApp): "encoding": "utf-8", "encoding_errors": "strict", "decode_responses": False, + "cache_config": CacheConfig(), } if dify_config.REDIS_USE_SENTINEL: @@ -83,8 +84,13 @@ def init_app(app: DifyApp): ClusterNode(host=node.split(":")[0], port=int(node.split(":")[1])) for node in dify_config.REDIS_CLUSTERS.split(",") ] - # FIXME: mypy error here, try to figure out how to fix it - redis_client.initialize(RedisCluster(startup_nodes=nodes, password=dify_config.REDIS_CLUSTERS_PASSWORD)) # type: ignore + redis_client.initialize( + RedisCluster( + startup_nodes=nodes, + password=dify_config.REDIS_CLUSTERS_PASSWORD, + cache_config=CacheConfig(), + ) + ) else: redis_params.update( {