ObanPowertools.Operator (oban_powertools v0.5.0)

Programmatic API for host applications to perform operational mutations on jobs and workflows.

Summary

Functions

bulk_cancel_jobs(repo, actor, job_ids, reason, opts \\ [])

Cancels a list of jobs, routing through the native repair flow. Returns %{successes: [job_id], failures: [{job_id, error}]}.

bulk_discard_jobs(repo, actor, job_ids, reason, opts \\ [])

Discards a list of jobs, routing through the native repair flow. Returns %{successes: [job_id], failures: [{job_id, error}]}.

bulk_retry_jobs(repo, actor, job_ids, reason, opts \\ [])

Retries a list of jobs from their current state, routing through the native repair flow. Returns %{successes: [job_id], failures: [{job_id, error}]}.

cancel_job(repo, actor, job_id, reason, opts \\ [])

Cancels a job, routing through the native repair flow.

discard_job(repo, actor, job_id, reason, opts \\ [])

Discards a job, routing through the native repair flow.

retry_job(repo, actor, job_id, reason, opts \\ [])

Retries a job from its current state, routing through the native repair flow.