taskiq
taskiq copied to clipboard
Distributed task queue with full async support
#249 Introduced the ability to configure when a task should be acknowledged. We should update the documentation to reflect this.
If a label with a type different from `str` is added anywhere in the worker task, the task will fail. ```python @broker.task async def generation_task(params: RequestParams, context: Annotated[Context, TaskiqDepends()]): result...
The diagram in the [Architecture Overview](https://taskiq-python.github.io/guide/architecture-overview.html) is broken and never loads. I tried with firefox and chrome.
I have a scenario where I know a time in the future (a variable time) that I want to trigger a task to execute only once, and I want to...
I can't seem to find anything about this in the docs. I'd like to assign a job (not a `task`) a unique name, so that if I were to try...
The following text is duplicated in https://taskiq-python.github.io/contrib.html. > We love contributions. This guide is for all folks who want to make taskiq better together. > > We have several rules...
I think it will really help if there is command like these: `$ taskiq list workers` ``` Worker name | State worker1 Listening worker2 Closing worker3 Starting ``` ---- `$ ...
Is it possible to pass a task to the queue by its path, rather than via import? Instead of: `file: my/package/module/tasks.py` ```python @broker.task async def add_one(value: int) -> int: return...
non-blocking sleep through a temporary increase in the number of running tasks on demand of the user. here is some use cases 1. some task A is waiting for result...
This feature should be useful if the project have a lot of tasks that are lightweight and most of the time awaiting for something. Ref: #128 and comment: https://github.com/taskiq-python/taskiq/pull/128#issuecomment-1843754982