{% extends "base.html" %}
{% block title %}{{ worker['name'] }} ยท Flower{% end %}
{% 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 details
{{ worker['name'] }}
{% if not read_only %}
{% end %}
Worker pool options
Worker pool options
{% for name,value in worker['stats'].get('pool', {}).items() %}
{{ humanize(name) }}
{{ humanize(value) }}
{% end %}
Worker PID
{% raw format_value(worker['stats'].get('pid')) %}
Prefetch Count
{% raw format_value(worker['stats'].get('prefetch_count')) %}
{% if not read_only %}
Pool controls
{% end %}
{% if worker['stats'].get('autoscaler', None) %}
Autoscaler options
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
{% if not read_only %}
{% end %}
{% 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'] }}
{% if not read_only %}
{% end %}
{% end %}
{% if not read_only %}
{% end %}
Processed tasks
{% for name,value in worker['stats']['total'].items() %}
{{ name }}
{{ format_count(value) }}
{% end %}
Active tasks
Name
UUID
Ack
PID
args
kwargs
{% for task in worker.get('active', {}) %}
{{ task['name'] }}
{% raw task_link(reverse_url('task', task['id']), task['id']) %}
{{ task['acknowledged'] }}
{{ task['worker_pid'] }}
{% raw format_value(task.get('args')) %}
{% raw format_value(task.get('kwargs')) %}
{% end %}
Scheduled tasks
Name
UUID
args
kwargs
{% for task in worker.get('scheduled', {}) %}
{{ task['request']['name'] }}
{% raw task_link(reverse_url('task', task['request']['id']), task['request']['id']) %}
{{ task['request']['args'] }}
{{ task['request']['kwargs'] }}
{% end %}
Reserved tasks
Name
UUID
args
kwargs
{% for task in worker.get('reserved', {}) %}
{{ task['name'] }}
{% raw task_link(reverse_url('task', task['id']), task['id']) %}
{{ task['args'] }}
{{ task['kwargs'] }}
{% end %}
Revoked tasks
UUID
{% for task in worker.get('revoked', []) %}
{% raw task_link(reverse_url('task', task), task) %}
{% end %}
Task limits
Task
Rate limit
Timeouts
{% for taskname in worker.get('registered', []) %}
{{ taskname }}
{% if not read_only %}
{% end %}
{% if not read_only %}
{% end %}
{% end %}
Configuration options
{% for name,value in sorted(worker.get('conf', {}).items()) %}
{% if value is not None %}