{{ type }}

{{ id }}

Comm: {{ address }} Workers: {{ workers | length }}
Dashboard: {{ scheduler | format_dashboard_address }} Total threads: {{ workers.values() | map(attribute='nthreads') | sum }}
Started: {{ started | datetime_from_timestamp | format_time_ago }} Total memory: {{ workers.values() | map(attribute='memory_limit') | sum | format_bytes }}

Workers

 {% for worker_name, worker in workers.items()|sort(attribute='1.name') %}

{{ worker["type"] }}: {{ worker["name"] }}

 {% if "gpu" in worker %} {% endif %} {% if "metrics" in worker %} {% endif %}
Comm: {{ worker_name }} Total threads: {{ worker["nthreads"] }}
Dashboard: {{ worker | format_dashboard_address }} Memory: {{ worker["memory_limit"] | format_bytes }}
Nanny: {{ worker["nanny"] }}
Local directory: {{ worker["local_directory"] }}
GPU: {{ worker["gpu"]["name"]}} GPU memory: {{ worker["gpu"]["memory-total"] | format_bytes }}
Tasks executing: {{ worker["metrics"]["executing"] }} Tasks in memory: {{ worker["metrics"]["in_memory"] }}
Tasks ready: {{ worker["metrics"]["ready"] }} Tasks in flight: {{ worker["metrics"]["in_flight"] }}
CPU usage: {{ worker["metrics"]["cpu"]}}% Last seen: {{ worker["last_seen"] | datetime_from_timestamp | format_time_ago }}
Memory usage: {{ worker["metrics"]["memory"] | format_bytes}} Spilled bytes: {{ worker["metrics"]["spilled_nbytes"]["disk"] | format_bytes }}
Read bytes: {{ worker["metrics"]["read_bytes"] | format_bytes }} Write bytes: {{ worker["metrics"]["write_bytes"] | format_bytes }}
{% endfor %}