debug redis

This commit is contained in:
2025-06-17 14:16:52 +09:30
parent 36bf2926ea
commit 2bb78f2135
+2
View File
@@ -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 = [