Structs§
- Callback
Config - Configuration for CEL callback expressions.
- List
Jobs Filter - List jobs with optional filters.
- Queue
Stats - Queue statistics.
- State
Timeseries Bucket - A bucketed count of jobs by state over time.
Enums§
- Default
Action - What
resolve_callbackshould do if no CEL conditions match or no expressions are configured. - Resolve
Outcome - Outcome of
resolve_callback.
Functions§
- bulk_
cancel - Cancel multiple jobs by ID. Only cancels non-terminal jobs.
- bulk_
retry - Retry multiple jobs by ID. Only retries failed, cancelled, or waiting_external jobs.
- cancel
- Cancel a single non-terminal job.
- complete_
external - Complete a waiting job via external callback.
- discard_
failed - Discard (delete) all failed jobs of a given kind.
- distinct_
kinds - Return all distinct job kinds.
- distinct_
queues - Return all distinct queue names.
- drain_
queue - Drain a queue: cancel all non-running, non-terminal jobs.
- fail_
external - Fail a waiting job via external callback.
- get_job
- Get a single job by ID.
- list_
jobs - List jobs matching the given filter.
- pause_
queue - Pause a queue. Affects all workers immediately.
- queue_
stats - Get statistics for all queues.
- register_
callback - Register a callback for a running job, writing the callback_id and timeout to the database immediately.
- register_
callback_ with_ config - Register a callback with optional CEL expressions.
- resolve_
callback - Resolve a callback by evaluating CEL expressions against the payload.
- resume_
queue - Resume a paused queue.
- retry
- Retry a single failed, cancelled, or waiting_external job.
- retry_
external - Retry a waiting job via external callback.
- retry_
failed_ by_ kind - Retry all failed jobs of a given kind.
- retry_
failed_ by_ queue - Retry all failed jobs in a given queue.
- state_
counts - Count jobs grouped by state.
- state_
timeseries - Return time-bucketed state counts over the last N minutes.