Skip to main content
arq logo

arq

v1.10.0 Apache-2.0

z4j-arq ยท Upstream project

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.10.0
Released
2026-08-28
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
  • 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

Read-only surface for arq's WorkerSettings.cron_jobs.

z4j-arqcron

z4j-arqcron

arq cron jobs are statically configured in WorkerSettings.cron_jobs. The adapter exposes their names and cron expressions as read-only inventory.

Learn more
More engines

Other z4j engines

Celery

Celery

The industry standard, covered end-to-end.

Learn more
RQ

RQ

Lightweight Redis queue, fully instrumented.

Learn more
Dramatiq

Dramatiq

Middleware-driven Dramatiq observability.

Learn more

Try z4j with arq

Install z4j arq docs