From 27c08dcddc7330a444f9ef59485e19bcb5db3a51 Mon Sep 17 00:00:00 2001 From: prachizala Date: Sun, 8 Nov 2026 21:12:28 +0530 Subject: [PATCH] feat(scripts): add queue inspection and worker health diagnostic tool Adds CLI diagnostic utility to inspect Redis queues and monitor pending message depths. Co-authored-by: Claude --- scripts/inspect_queue.py | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) create mode 100644 scripts/inspect_queue.py diff --git a/scripts/inspect_queue.py b/scripts/inspect_queue.py new file mode 100644 index 0000000..2b4b957 --- /dev/null +++ b/scripts/inspect_queue.py @@ -0,0 +1,19 @@ +import sys +import redis + +def inspect_celery_queues(redis_host: str = "localhost", redis_port: int = 6379): + try: + r = redis.Redis(host=redis_host, port=redis_port, decode_responses=True) + r.ping() + print("Connected to Redis broker.") + except Exception as e: + print(f"Failed to connect to Redis: {e}") + return + + queues = ["default", "celery", "dead_letter"] + for q in queues: + length = r.llen(q) + print(f"Queue '{q}': {length} pending messages") + +if __name__ == "__main__": + inspect_celery_queues()