{% extends "base.html" %} {% block navbar %} {% module Template("navbar.html", active_tab="workers") %} {% end %} {% block container %}
{% for name,value in worker['stats']['pool'].items() %} {% end %}
Worker pool options
{{ humanize(name) }} {{ humanize(value) }}
Worker PID {{ worker['stats'].get('pid', 'N/A')}}
Prefetch Count {{ worker['stats'].get('prefetch_count', 'N/A')}}
Pool size control
{% if worker['stats'].get('autoscaler', None) %}
{% for name,value in worker['stats']['autoscaler'].items() %} {% end %}
Autoscaler options
{{ humanize(name) }} {{ humanize(value) }}
{% end %}
{% for name,value in (worker['stats'].get('consumer', None) or worker['stats'])['broker'].items() %} {% end %}
Broker options
{{ humanize(name) }} {{ value }}

Active queues being consumed from

{% for queue in worker.get('active_queues', []) %} {% end %}
Name Exclusive Durable Routing key No ACK Alias Queue arguments Binding arguments Auto delete
{{ queue['name'] }} {{ queue['exclusive'] }} {{ queue['durable'] }} {{ queue['routing_key'] }} {{ queue['no_ack'] }} {{ queue['alias'] }} {{ queue['queue_arguments'] }} {{ queue['binding_arguments'] }} {{ queue['auto_delete'] }}

Processed number of completed tasks

{% for name,value in worker['stats']['total'].items() %} {% end %}
{{ name }} {{ value }}

Active currently executing tasks

{% for task in worker.get('active', {}) %} {% end %}
Name UUID Ack PID args kwargs
{{ task['name'] }} {{ task['id'] }} {{ task['acknowledged'] }} {{ task['worker_pid'] }} {{ task.get('args', 'N/A') }} {{ task.get('kwargs', 'N/A') }}

Scheduled scheduled (eta/countdown/retry) tasks

{% for task in worker.get('scheduled', {}) %} {% end %}
Name UUID args kwargs
{{ task['request']['name'] }} {{ task['request']['id'] }} {{ task['request']['args'] }} {{ task['request']['kwargs'] }}

Reserved tasks that have been received, but are still waiting to be executed

{% for task in worker.get('reserved', {}) %} {% end %}
Name UUID args kwargs
{{ task['name'] }} {{ task['id'] }} {{ task['args'] }} {{ task['kwargs'] }}

Revoked cancelled tasks

{% for task in worker.get('revoked', []) %} {% end %}
UUID
{{ task }}

Task limits

{% for taskname in worker.get('registered', []) %} {% end %}
Task name Rate limit Timeouts
{{ taskname }}
{% for name,value in sorted(worker.get('conf', {}).items()) %} {% if value is not None %} {% end %} {% end %}
Configuration options
{{ name }} {{ value }}
{% if isinstance(worker['stats'].get('rusage', None), dict) %} {% for name, value in worker['stats']['rusage'].items() %} {% end %} {% end %}
System usage statistics
{{ name }} {{ value }}
{% end %}