taskiq
taskiq copied to clipboard
taskiq-python
Distributed task queue with full async support
`taskiq == 0.11.18` ```python import asyncio from typing import Annotated from taskiq import Context from taskiq import TaskiqDepends from taskiq import InMemoryBroker broker = InMemoryBroker() @broker.task("my_task") async def my_task(context: Annotated[Context,...
When using taskiq-redis with Redis Sentinel in an async environment (EKS), I’m getting this abruptly 5-6 times (maybe more) in a day. But it restarts automatically and then works fine....
When the message queue isn't reachable (i.e. Redis is offline), the receiver retries so quickly that the CPU goes to 100%. This should be an easy fix, such as adding...
On task error, `task.AsyncTaskiqTask.get_result` will [emit `"Cannot parse..."` log warnings](https://github.com/taskiq-python/taskiq/blob/master/taskiq/task.py#L73) that are not really helpful especially considering detailed error information is available elsewhere. Moreover, the result both `return_value=None` which means...
I want to propose a possible general API for task cancellation. I don't have much experience with distributed tasks so my goal is to spark conversation and if the concept...
Hi! As discuss in #290 #348 In this PR, I'm adding the ability to run scheduled tasks every X seconds. This fills a gap that CRON doesn't allow. To avoid...
_Maybe is a misconfiguration option or I don't know docker or maybe both_ When you enable `--no-configure-logging` with `--reload` in docker the no configure get disabled or some strange bug...
I noticed that the scheduler does not have a handler set for sigterm, which leads to the scheduler as a pid 1 process not properly handling the sigterm signals sent...
When trying to use TaskIQ for distributing slow-to-start processes (due to AI imports) meant for long-running tasks, we kept running into issues where TaskIQ would start our worker subprocesses from...
Metadata
Owner
Metadata
Distributed task queue with full async support