arq

v1.13.0 Apache-2.0

Async Redis queue for FastAPI-era Python.

arq has no native re-enqueue-by-id primitive, so retry requires an explicit submit with the function name and complete inputs. Event capture chains onto arq's WorkerSettings on_job_start / on_job_end hooks.

Docs PyPI: z4j-arq Source Upstream

Latest: v1.13.0
Released: 2026-10-19
License: Apache-2.0

Install

bash

pip install z4j-arq

Native actions

submit_task
cancel_task (Job.abort)

Not supported

retry_task
bulk_retry
requeue_dead_letter
list_dead_letters
purge_queue
restart_worker
rate_limit

These are engine-level limitations: the underlying engine does not expose the primitives required to support these actions.

Wiring

How z4j plugs in

Event capture

attach_to_worker_settings() chains onto on_job_start / on_job_end; it must be attached for lifecycle capture.

Reconciliation

arq.jobs.Job.status() + result_info(): clean deferred/queued/in_progress/complete mapping.

Paired scheduler

arq cron_jobs

Manage code-defined arq cron jobs with durable overrides.

z4j-arqcron

Binds to the actual arq Worker and applies durable dashboard create, edit, pause and delete operations. Native cron timing and task registration remain under application control.

Learn more

More engines