Durable Execution Worker — Admin Guide

SELECT count(*) AS pending_messages
FROM pgmq.q_workflow_execution_queue
WHERE vt <= now();

SELECT count(*) AS dlq_messages
FROM pgmq.q_workflow_dlq;

-- View DLQ message details
SELECT msg_id, enqueued_at, message->>'execution_id' AS execution_id,
       message->>'error' AS error, message->>'failed_at' AS failed_at
FROM pgmq.q_workflow_dlq
ORDER BY enqueued_at DESC
LIMIT 20;

SELECT organization_id, worker_running, worker_last_run_at, worker_last_batch_size
FROM fw_module_settings
WHERE fw_execution_worker_enabled = true;

-- Move a message back to the main queue
WITH dlq_msg AS (
  SELECT msg_id, message FROM pgmq.q_workflow_dlq WHERE msg_id = :msg_id
)
SELECT pgmq.send('workflow_execution_queue', 
  jsonb_set(message, '{attempt}', '1'::jsonb)
) FROM dlq_msg;

-- Then delete from DLQ
SELECT pgmq.delete('workflow_dlq', :msg_id);

DELETE FROM pgmq.q_workflow_dlq
WHERE enqueued_at < now() - interval '30 days';