feat(queue): add queue health endpoint

Author: haasonsaas

agent_pm/observability/dashboard.py

@@ -4,8 +4,9 @@
 
 from dataclasses import dataclass
 
-from ..storage.redis import count_dead_letters
-from ..storage.tasks import get_task_queue
+from agent_pm.storage.redis import count_dead_letters
+from agent_pm.storage.tasks import get_task_queue
+from agent_pm.settings import settings
 
 
 @dataclass
@@ -17,7 +18,7 @@ class QueueHealth:
 
 async def gather_queue_health() -> QueueHealth:
     queue = await get_task_queue()
-    client = await queue.get_client()  # type: ignore[attr-defined]
-    dead_letters = await count_dead_letters(client)
-    auto_triage_enabled = bool(queue)
+    client = getattr(queue, "_redis", None)
+    dead_letters = await count_dead_letters(client) if client else 0
+    auto_triage_enabled = bool(settings.task_queue_auto_requeue_errors)
     return QueueHealth(queue_name=getattr(queue, "queue_name", "unknown"), dead_letters=dead_letters, auto_triage_enabled=auto_triage_enabled)

app.py

@@ -41,6 +41,7 @@
     SlackDigest,
     TicketPlan,
 )
+from agent_pm.observability.dashboard import gather_queue_health
 from agent_pm.observability.export import schedule_trace_export
 from agent_pm.observability.logging import configure_logging
 from agent_pm.observability.metrics import (
@@ -105,6 +106,16 @@ class FollowupUpdate(BaseModel):
 app = lifespan_app
 
 
+@app.get("/tasks/health", dependencies=[Depends(enforce_rate_limit)])
+async def task_queue_health(_admin_key: AdminKeyDep = None) -> dict[str, Any]:
+    data = await gather_queue_health()
+    return {
+        "queue": data.queue_name,
+        "dead_letters": data.dead_letters,
+        "auto_triage_enabled": data.auto_triage_enabled,
+    }
+
+
 async def ensure_project_allowed(plan: TicketPlan) -> TicketPlan:
     allowed = settings.allowed_projects
     if allowed and plan.project_key not in allowed:

tests/test_tasks_api.py

@@ -37,6 +37,10 @@ async def test_tasks_admin_endpoints_with_memory_backend(monkeypatch):
         worker_resp = await client.get("/tasks/workers")
         assert worker_resp.status_code == 200
         assert worker_resp.json() == {"workers": {}}
+
+        health_resp = await client.get("/tasks/health")
+        assert health_resp.status_code == 200
+        assert "queue" in health_resp.json()
         await client.cleanup()
     finally:
         app.dependency_overrides.clear()