taskiq

v1.13.0 Apache-2.0

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.13.0
Released: 2026-10-19
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
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

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

Dashboard management for TaskIQ label schedules.

z4j-taskiqscheduler

Wraps the actual stock LabelScheduleSource with persistent dashboard overrides. It rechecks cached definitions before dispatch and preserves edits and pauses across producer restart.

Learn more

More engines