diff --git a/websocket_server/redis_utils.py b/websocket_server/redis_utils.py index c6cd6fd..53746c2 100644 --- a/websocket_server/redis_utils.py +++ b/websocket_server/redis_utils.py @@ -19,8 +19,10 @@ def redis_subscribe(worker_id): Redis Pub/Sub monitor for a specific worker. Subscribes to worker status and queue keys and sets dispatch flags accordingly. """ + redis_client = get_redis_client() redis_client.config_set("notify-keyspace-events", "KA") + logger.debug(f"Total connections in pool: {len(redis_client.connection_pool._available_connections)}") pubsub = redis_client.pubsub() channels = [