Mirrors/Dispatcharr
1
0
Fork 1
mirror of https://github.com/Dispatcharr/Dispatcharr.git synced 2026-07-17 16:50:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Lowered max retries and timeout for redis client.

Browse source
This commit is contained in:
SergeantPanda 2025-03-22 11:36:28 -05:00
parent cb013c0a0d
commit 071efaf017
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
core/utils.py
View file

@ -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