{% extends "_base.html" %} {% set active_page = "queues" %} {% from "_partials/table.html" import styled_table, table_header, table_body, table_row %} {% block title %}Queues — TaskQ Admin{% endblock %} {% block content %}

Queues

{% if orphan_queues %}
Warning: {% set orphan_list = orphan_queues | list | sort %} {% if orphan_list | length == 1 %} Queue {{ orphan_list[0] }} has pending jobs but no alive worker. {% else %} Queues {% for q in orphan_list %}{{ q }}{% if not loop.last %}, {% endif %}{% endfor %} have pending jobs but no alive worker. {% endif %} Check workers
{% endif %}
{% if queues %} {% call styled_table() %} {{ table_header(["Queue", "Pending", "Scheduled", "Running", "Failed"]) }} {% call table_body() %} {% for q in queues %} {% call table_row() %} {{ q.queue }} {% if orphan_queues and q.queue in orphan_queues and q.pending_count > 0 %} {{ q.pending_count }} {% elif q.pending_count > 0 %} {{ q.pending_count }} {% else %} {{ q.pending_count }} {% endif %} {% if q.scheduled_count > 0 %} {{ q.scheduled_count }} {% else %} {{ q.scheduled_count }} {% endif %} {% if q.running_count > 0 %} {{ q.running_count }} {% else %} {{ q.running_count }} {% endif %} {% set fc = q.failed_count | default(0) %} {% if fc > 0 %} {{ fc }} {% else %} {{ fc }} {% endif %} {% endcall %} {% endfor %} {% endcall %} {% endcall %} {% else %}

No queues with active jobs found.

{% endif %}
{% endblock %}