Skip to main content
taskiq logo

taskiq

v1.0 (new)

z4j-taskiq · Upstream project

Broker-agnostic async task framework.

taskiq's value is broker-flexibility (Redis, NATS, AMQP). Per-broker quirks mean cancel/retry need per-broker drivers; v1.0 ships the universal submit_task + reconcile path. Event capture via Z4JTaskiqMiddleware.

Engine docs PyPI: z4j-taskiq

Install

bash 
pip install z4j-taskiq

Native actions

  • submit_task

Brain-polyfilled actions

  • retry_task
  • bulk_retry
  • requeue_dead_letter

The brain fetches the original args from its tasks table and lowers to submit_task transparently. The dashboard shows the same button regardless.

Not supported

  • cancel_task (broker-specific; v1.1 per-broker)
  • restart_worker (graceful self-exit)
  • rate_limit

Engine-level limitations, not a roadmap gap. These actions require primitives the engine does not expose.

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 any custom ScheduleSource). v1 supports list + read + delete.

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