Worker pool options
{% for name,value in worker.stats['pool'].items() %}
{{ humanize(name) }} |
{{ humanize(value) }} |
{% end %}
Worker PID |
{{ worker.stats.get('pid', '')}} |
{% 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.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 |
Start time |
Ack |
PID |
args |
kwargs |
{% for task in worker.active_tasks %}
{{ task['name'] }} |
{{ task['id'] }} |
{{ humanize(task['time_start'], type='time') }} |
{{ task['acknowledged'] }} |
{{ task['worker_pid'] }} |
{{ task['args'] }} |
{{ task['kwargs'] }} |
{% end %}
Scheduled scheduled (eta/countdown/retry) tasks
Name |
UUID |
args |
kwargs |
{% for task in worker.scheduled_tasks %}
{{ 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.reserved_tasks %}
{{ task['name'] }} |
{{ task['id'] }} |
{{ task['args'] }} |
{{ task['kwargs'] }} |
{% end %}
Revoked cancelled tasks
Name |
ID |
args |
kwargs |
{% for task in worker.revoked_tasks %}
|
{{ task }} |
|
|
{% end %}
Task limits
Task name |
Rate limit |
Timeouts |
{% for taskname in worker.registered_tasks %}
{{ taskname }} |
|
|
{% end %}
Configuration options
{% for name,value in sorted(worker.conf.items()) %}
{% if value is not None %}
{{ name }} |
{{ value }} |
{% end %}
{% end %}