{% extends "base.html" %} {% block navbar %} {% module Template("navbar.html", active_tab="workers", absolute_url=absolute_url) %} {% 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', '')}}
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.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.active_tasks %} {% end %}
Name UUID Start time Ack PID args kwargs
{{ task['name'] }} {{ task['id'] }} {{ humanize(task['time_start'], type='time') }} {{ task['acknowledged'] }} {{ task['worker_pid'] }} {{ task['args'] }} {{ task['kwargs'] }}

Scheduled scheduled (eta/countdown/retry) tasks

{% for task in worker.scheduled_tasks %} {% 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.reserved_tasks %} {% end %}
Name UUID args kwargs
{{ task['name'] }} {{ task['id'] }} {{ task['args'] }} {{ task['kwargs'] }}

Revoked cancelled tasks

{% for task in worker.revoked_tasks %} {% end %}
Name ID args kwargs
{{ task }}

Task limits

{% for taskname in worker.registered_tasks %} {% end %}
Task name Rate limit Timeouts
{{ taskname }}
{% for name,value in sorted(worker.conf.items()) %} {% if value is not None %} {% end %} {% end %}
Configuration options
{{ name }} {{ value }}
{% end %}