Queue Depths
queue_depthsCount waiting messages in each RabbitMQ or Redis queue and identify the workers consuming them to diagnose backed-up or unrouted Celery tasks.
Instructions
Count waiting messages per queue and show which workers consume each one. Works on RabbitMQ and Redis.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| queues | No | Queue names to check. Defaults to configured queues plus every queue a worker consumes. | |
| timeout | No | Seconds to wait for worker replies. Defaults to CELERY_INSPECT_TIMEOUT. |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||