Durable.Queue.Adapters.Postgres (Durable v0.1.0-rc)

View Source

PostgreSQL-based queue adapter using the workflow_executions table.

Uses FOR UPDATE SKIP LOCKED for atomic job claiming without blocking. This ensures that multiple pollers can safely claim jobs without processing the same job twice.

Summary

Functions

ack(config, job_id, lock_token)

heartbeat(config, job_id, lock_token)

nack(config, job_id, reason, lock_token)

reschedule(config, job_id, run_at, lock_token)