Skip to main content
taskiq logo

taskiq

v1.10.0 Apache-2.0

z4j-taskiq ยท Upstream project

Broker-agnostic async task framework.

taskiq's value is broker-flexibility (Redis, NATS, AMQP). z4j-taskiq rides taskiq's broker-independent layer, which has no portable cancel or retry primitive, so it ships the universal submit_task plus reconcile path. Event capture via Z4JTaskiqMiddleware.

Docs PyPI: z4j-taskiq Source Upstream
Latest
v1.10.0
Released
2026-08-28
License
Apache-2.0

Install

bash 
pip install z4j-taskiq

Native actions

  • submit_task

Not supported

  • cancel_task (taskiq has no broker-agnostic cancel primitive)
  • 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

Z4JTaskiqMiddleware: pre_send / pre_execute / post_execute / on_error.

Reconciliation

result_backend.is_result_ready() + get_result(). Works across every backend taskiq ships.

Paired scheduler

taskiq scheduler

Wraps LabelScheduleSource + custom sources.

z4j-taskiqscheduler

z4j-taskiqscheduler

Wraps taskiq's LabelScheduleSource (or a custom ScheduleSource) as list/read 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 taskiq

Install z4j taskiq docs