Skip to main content
SupaProxy uses BullMQ (Redis) for background jobs: conversation lifecycle transitions, cold message generation, and conversation stats.

List queues

GET /api/org/queues
{
  "queues": [
    {"name": "lifecycle", "waiting": 0, "active": 1, "completed": 500, "failed": 2, "delayed": 0},
    {"name": "cold-messages", "waiting": 3, "active": 0, "completed": 120, "failed": 0, "delayed": 0},
    {"name": "conversation-stats", "waiting": 1, "active": 1, "completed": 300, "failed": 5, "delayed": 0}
  ]
}

List failed jobs

GET /api/org/queues/:name/failed
{
  "jobs": [{
    "id": "42",
    "failedReason": "Connection to AI provider timed out",
    "attemptsMade": 3,
    "data": {"conversationId": "conv-abc123"}
  }]
}

Retry all failed jobs

POST /api/org/queues/:name/retry-all
{"status": "ok", "retried": 5}

Drain queue

POST /api/org/queues/:name/drain
Clears all pending jobs from the queue.
{"status": "ok"}