{% extends "base.html" %}
{% block navbar %}
{% module Template("navbar.html", active_tab="workers") %}
{% end %}
{% block container %}
{% set other = {key: value for key, value in worker['stats'].items() if key not in
'pool pid prefetch_count autoscaler consumer broker clock total rusage'.split()} %}
{{ worker['name'] }}
Refresh
Worker pool options
{% for name,value in worker['stats'].get('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
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'] }}
Cancel
Consumer
{% end %}
Processed tasks
{% for name,value in worker['stats']['total'].items() %}
{{ name }}
{{ value }}
{% end %}
Active 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 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
Name
UUID
args
kwargs
{% for task in worker.get('reserved', {}) %}
{{ task['name'] }}
{{ task['id'] }}
{{ task['args'] }}
{{ task['kwargs'] }}
{% end %}
Revoked tasks
UUID
{% for task in worker.get('revoked', []) %}
{{ task }}
{% end %}
Task limits
Task
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 %}
{% if other %}
Other statistics
{% for name, value in other.items() %}
{{ name }}
{{ value }}
{% end %}
{% end %}
{% end %}