Documentation: https://taskiq-python.github.io/
What is taskiq?
Taskiq is an asynchronous distributed task queue for python. This project takes inspiration from big projects such as Celery and Dramatiq. But taskiq can send and run both the sync and async functions, has integration with popular async frameworks, such as FastAPI and AioHTTP.
Also, we use PEP-612 to provide the best autosuggestions possible. All code is type-hinted.
Installation
This project can be installed using pip:
pip install taskiq
Or it can be installed directly from git:
pip install git+https://github.com/taskiq-python/taskiq
Usage
At first you need to create a broker. Broker is an object that can communicate to workers using distributed queues.
We have different brokers for different queue backends. For example, we have a broker for NATS, Redis, RabbitMQ, Kafka and even more. Choose the one that fits you and create an instance.
from taskiq_nats import JetStreamBroker
broker = JetStreamBroker("nats://localhost:4222", queue="my_queue")
Declaring tasks is as easy as declaring a function. Just add a decorator to your function and you are ready to go.
import asyncio
from taskiq_nats import JetStreamBroker
broker = JetStreamBroker("nats://localhost:4222", queue="my_queue2")
@broker.task
async def my_task(a: int, b: int) -> None:
print("AB", a + b)
async def main():
await broker.startup()
await my_task.kiq(1, 2)
await broker.shutdown()
if __name__ == "__main__":
asyncio.run(main())
The message is going to be sent to the broker and then to the worker. The worker will execute the function. To start worker processes, just run the following command:
taskiq worker path.to.the.module:broker
Where path.to.the.module is the path to the module where the broker is defined and broker is the name of the broker variable.
If you have tasks in different modules, you can ask taskiq to automatically import them by passing the --fs-discover flag:
taskiq worker path.to.the.module:broker --fs-discover
It will import all modules called tasks.py in the current directory and all subdirectories.
Also, we support hot reload for workers. To enable it, just pass the --reload flag. It will reload the worker when the code changes (To use it, install taskiq with reload extra. E.g pip install taskiq[reload]).
Also, we have cool integrations with popular async frameworks. For example, we have an integration with FastAPI or AioHTTP. You can use it to reuse dependencies from your web app in your tasks.
Read about all features in our documentation: https://taskiq-python.github.io/
Local development
Linting
We use pre-commit to do linting locally.
After cloning this project, please install pre-commit. It helps fix files before committing changes.
pre-commit install
Testing
Pytest can run without any additional actions or options.
pytest
Docs
To run docs locally, you need to install yarn.
First, you need to install dependencies.
yarn install
After that you can set up a docs server by running:
yarn docs:dev
Metadata
Release files for taskiq 0.13.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| taskiq-0.13.0.tar.gz | 411.2 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| taskiq-0.13.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 506.0 kB
Release files / taskiq-0.13.0.tar.gz
| Download URL | taskiq-0.13.0.tar.gz |
|---|---|
| Size | 411.2 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
7d56609a6c5a20b0c9da67e9f310ec9640266f620b8f81880bccd5f16913e687
|
|
BLAKE2b-256 checksum How to use checksums |
09c6a6e5a15158e1db35b458f68f40b3e44c32134d7edad6bfcdb5bbd4128174
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
uv/0.12.19 {"installer":{"name":"uv","version":"0.12.19","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
|
Release files / taskiq-0.13.0-py3-none-any.whl
| Download URL | taskiq-0.13.0-py3-none-any.whl |
|---|---|
| Size | 94.9 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
b51e1961d8919bc897caa6f5484ac08d812341413a20a3704b69c597c4c154d2
|
|
BLAKE2b-256 checksum How to use checksums |
599cc4fb8085424ef1c5479877f0f16f8dc4b406dcf6f367d51464bbf134d086
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
uv/0.12.19 {"installer":{"name":"uv","version":"0.12.19","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
|
