From 071efaf0173a7de3445bdf6418b345d3f042f351 Mon Sep 17 00:00:00 2001 From: SergeantPanda Date: Sat, 22 Mar 2025 11:36:28 -0500 Subject: [PATCH] Lowered max retries and timeout for redis client. --- core/utils.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/utils.py b/core/utils.py index e61b0c14..4e472ef2 100644 --- a/core/utils.py +++ b/core/utils.py @@ -57,7 +57,7 @@ def get_redis_client(max_retries=5, retry_interval=1): logger.error(f"Unexpected error connecting to Redis: {e}") return None -def get_redis_pubsub_client(max_retries=5, retry_interval=3): +def get_redis_pubsub_client(max_retries=5, retry_interval=1): """Get Redis client optimized for PubSub operations""" retry_count = 0 while retry_count < max_retries: @@ -133,8 +133,8 @@ def execute_redis_command(redis_client, command_func, default_return=None): return default_return # Initialize the global clients with retry logic -redis_client = get_redis_client(max_retries=10, retry_interval=1) -redis_pubsub_client = get_redis_pubsub_client(max_retries=10, retry_interval=1) +redis_client = get_redis_client() +redis_pubsub_client = get_redis_pubsub_client() # Import and initialize the PubSub manager from .redis_pubsub import get_pubsub_manager