z4j-celery
The Celery engine adapter for z4j.
Streams every task lifecycle event from your Celery workers to the z4j brain and accepts operator control actions from the dashboard. Pair with z4j-celerybeat to manage periodic / cron schedules.
Compatibility
- Celery 5.2+ (no upper cap)
- Python 3.11+
Full per-adapter matrix at https://z4j.dev/reference/compatibility/.
What it ships
| Capability | Notes |
|---|---|
| Task lifecycle events | submitted, started, succeeded, failed, retried, revoked |
| Task discovery | runtime registry merge + static tasks.py scan |
| Submit / retry / cancel | direct against the Celery app |
| Bulk retry | filter-driven; re-enqueues matching tasks |
| Purge queue | with confirm-token guard |
| Requeue dead-letter | from the configured DLX |
| Restart worker | broadcast pool restart, zero task loss |
| Pool grow / shrink | via Celery's control API |
| Rate limit | broker-side via Celery's control channel |
| Reconcile task | via the result backend |
The widest feature coverage of any z4j engine adapter, Celery's rich remote-control surface lets z4j ship capabilities other engines can't match (pool restart with zero task loss, broker-side rate limiting).
Install
pip install z4j-celery z4j-celerybeat
Pair with a framework adapter:
pip install z4j-django z4j-celery z4j-celerybeat # Django
pip install z4j-flask z4j-celery z4j-celerybeat # Flask
pip install z4j-fastapi z4j-celery z4j-celerybeat # FastAPI
pip install z4j-bare z4j-celery z4j-celerybeat # framework-free worker
Pairs with
z4j-celerybeat, schedule adapter for Celery Beat / django-celery-beat
Reliability
- No exception from the adapter ever propagates back into your Celery workers or signal handlers.
- Events buffer locally when z4j is unreachable; your workers never slow down or block on network I/O.
Documentation
Full docs at z4j.dev/engines/celery/.
License
Apache-2.0, see LICENSE.
Links
- Homepage: https://z4j.com
- Documentation: https://z4j.dev
- PyPI: https://pypi.org/project/z4j-celery/
- Issues: https://github.com/z4jdev/z4j-celery/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_celery-1.8.0.tar.gz.
File metadata
- Download URL: z4j_celery-1.8.0.tar.gz
- Upload date:
- Size: 75.8 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/6.2.0 CPython/3.14.4
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
56e83f330b720b50d1fe107d50138f43eeecb8d64541145a228a89dd81c520e9
|
|
| MD5 |
610577ccb7a65c60916841ae202ce066
|
|
| BLAKE2b-256 |
1c68f032841546c8f5c5246782086ca733c3bedc4d753a8f578e74e47864aa13
|
File details
Details for the file z4j_celery-1.8.0-py3-none-any.whl.
File metadata
- Download URL: z4j_celery-1.8.0-py3-none-any.whl
- Upload date:
- Size: 70.4 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 |
cbc58f0d305f68a654c2d1cc9968006a1d85b0cdb12d012730583baf23f9fa6d
|
|
| MD5 |
4f20c141805575fdaf4f6e9c32577fec
|
|
| BLAKE2b-256 |
15ec43a1da9732818a95686e5c3540610b827dba189ce62d34a8737f4dac3780
|
