Postgres-based job queue using FOR UPDATE SKIP LOCKED

job_queue.sql

WITH next_job AS (
    SELECT 
        id,
        type,
        payload,
        created_at
    FROM jobs
    WHERE created_at <= ? 
    ORDER BY created_at
    FOR UPDATE SKIP LOCKED
    LIMIT 1
)
DELETE FROM jobs
WHERE id IN (SELECT id FROM next_job)
RETURNING *;