An extension that enables truly global concurrency, global rate limiting, partitioned rate limiting, unique bulk inserts, and auto insert batching.
Extend the base worker with advanced options like encryption, enforced structure, and recorded output.
Insert jobs and await the results across any number of nodes, i.e. persistent distributed tasks.
Advanced helpers for testing supervised Oban instances, workers, and making assertions about enqueued jobs.
Configure cron scheduling at runtime, globally, across an entire cluster.
Rescue orphaned jobs reliably, without the possibility of duplicate execution.
Delete historic jobs on a flexible CRON schedule using configurable limits with per-queue, per-worker, and per-state overrides.
Configure queues at runtime, persist changes across restarts, and optionally limit queues to certain nodes.
Automatically adjust job priorities to prevent queue starvation and ensure all jobs are eventually processed.
Process jobs in groups while tracking overall progress across all nodes and executing optional callbacks.
Process jobs atomically in groups based on size or timeout, with robust error handling semantics.
Compose workers together with arbitrary dependencies between jobs, allowing sequential, fan-out and fan-in execution.