z4j-taskiq
The TaskIQ engine adapter for z4j.
Streams every TaskIQ task lifecycle event from your async workers to z4j and accepts operator control actions from the dashboard. Pair with z4j-taskiqscheduler to surface taskiq-scheduler periodic jobs.
Compatibility
- TaskIQ 0.11+ and <1 (capped below the eventual TaskIQ 1.0 breaking-major)
- Python 3.11+
Full per-adapter matrix at https://z4j.dev/reference/compatibility/.
What it ships
| Capability | Notes |
|---|---|
| Task lifecycle events | enqueued, started, succeeded, failed |
| Task discovery | runtime broker task registry (broker.get_all_tasks()) |
| Submit task | enqueue a registered task against the TaskIQ broker via .kiq() |
| Reconcile task | via the configured TaskIQ result backend |
Async-native, uses TaskIQ's middleware hook system.
Control actions beyond submit (retry, cancel, bulk retry, purge queue) are not yet supported. TaskIQ's broker-agnostic design means each broker needs its own implementation, so the dashboard greys these actions out for TaskIQ engines until per-broker support lands.
Install
pip install z4j-taskiq z4j-taskiqscheduler
Pair with a framework adapter:
pip install z4j-fastapi z4j-taskiq z4j-taskiqscheduler
pip install z4j-bare z4j-taskiq z4j-taskiqscheduler # framework-free worker
Pairs with
z4j-taskiqscheduler, schedule adapter for taskiq-scheduler
Reliability
- No exception from the adapter ever propagates back into TaskIQ middleware or your task code.
- Events buffer locally when z4j is unreachable; workers never block on network I/O.
Documentation
Full docs at z4j.dev/engines/taskiq/.
License
Apache-2.0, see LICENSE.
Links
- Homepage: https://z4j.com
- Documentation: https://z4j.dev
- PyPI: https://pypi.org/project/z4j-taskiq/
- Issues: https://github.com/z4jdev/z4j-taskiq/issues
- Changelog: CHANGELOG.md
- Security: security@z4j.com (see SECURITY.md)
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file z4j_taskiq-1.8.0.tar.gz.
File metadata
- Download URL: z4j_taskiq-1.8.0.tar.gz
- Upload date:
- Size: 18.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/6.2.0 CPython/3.14.4
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
55babd26f5df3462a6692e19e975f288dcd152a2b8f994e659602b8e76e26703
|
|
| MD5 |
e7492b7d69b693ccfd382848846c943b
|
|
| BLAKE2b-256 |
a6ef664ffd3650060546712b62df72a3ec5662fbf9f89fd818ad0dc6ad144756
|
File details
Details for the file z4j_taskiq-1.8.0-py3-none-any.whl.
File metadata
- Download URL: z4j_taskiq-1.8.0-py3-none-any.whl
- Upload date:
- Size: 14.5 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/6.2.0 CPython/3.14.4
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
e689d583b7d37695daf4ef71fbcec471da9894a372813c1fbfb4b79ab7b7d5f0
|
|
| MD5 |
49a781549e5b56c2e8e5c076c50c1275
|
|
| BLAKE2b-256 |
0118620b8167440c0950baaf9ed143b358d797145806c3ab0c846adfd214be85
|
