Worker pool options
{% for name,value in worker['stats']['pool'].items() %}
{{ humanize(name) }} |
{{ humanize(value) }} |
{% end %}
Worker PID |
{{ worker['stats'].get('pid', 'N/A')}} |
Prefetch Count |
{{ worker['stats'].get('prefetch_count', 'N/A')}} |
{% if worker['stats'].get('autoscaler', None) %}
Autoscaler options
{% for name,value in worker['stats']['autoscaler'].items() %}
{{ humanize(name) }} |
{{ humanize(value) }} |
{% end %}
{% end %}
Broker options
{% for name,value in (worker['stats'].get('consumer', None) or worker['stats'])['broker'].items() %}
{{ humanize(name) }} |
{{ value }} |
{% end %}
Active queues being consumed from
Name |
Exclusive |
Durable |
Routing key |
No ACK |
Alias |
Queue arguments |
Binding arguments |
Auto delete |
|
{% for queue in worker.get('active_queues', []) %}
{{ queue['name'] }} |
{{ queue['exclusive'] }} |
{{ queue['durable'] }} |
{{ queue['routing_key'] }} |
{{ queue['no_ack'] }} |
{{ queue['alias'] }} |
{{ queue['queue_arguments'] }} |
{{ queue['binding_arguments'] }} |
{{ queue['auto_delete'] }} |
|
{% end %}
Processed number of completed tasks
{% for name,value in worker['stats']['total'].items() %}
{{ name }} |
{{ value }} |
{% end %}
Active currently executing tasks
Name |
UUID |
Ack |
PID |
args |
kwargs |
{% for task in worker.get('active', {}) %}
{{ task['name'] }} |
{{ task['id'] }} |
{{ task['acknowledged'] }} |
{{ task['worker_pid'] }} |
{{ task.get('args', 'N/A') }} |
{{ task.get('kwargs', 'N/A') }} |
{% end %}
Scheduled scheduled (eta/countdown/retry) tasks
Name |
UUID |
args |
kwargs |
{% for task in worker.get('scheduled', {}) %}
{{ task['request']['name'] }} |
{{ task['request']['id'] }} |
{{ task['request']['args'] }} |
{{ task['request']['kwargs'] }} |
{% end %}
Reserved tasks that have been received, but are still waiting to be executed
Name |
UUID |
args |
kwargs |
{% for task in worker.get('reserved', {}) %}
{{ task['name'] }} |
{{ task['id'] }} |
{{ task['args'] }} |
{{ task['kwargs'] }} |
{% end %}
Revoked cancelled tasks
UUID |
{% for task in worker.get('revoked', []) %}
{{ task }} |
{% end %}
Task limits
Task name |
Rate limit |
Timeouts |
{% for taskname in worker.get('registered', []) %}
{{ taskname }} |
|
|
{% end %}
Configuration options
{% for name,value in sorted(worker.get('conf', {}).items()) %}
{% if value is not None %}
{{ name }} |
{{ value }} |
{% end %}
{% end %}
System usage statistics
{% if isinstance(worker['stats'].get('rusage', None), dict) %}
{% for name, value in worker['stats']['rusage'].items() %}
{{ name }} |
{{ value }} |
{% end %}
{% end %}