taskiq
taskiq copied to clipboard
Distributed task queue with full async support
Hi, thanks for the awesome library. I am trying to add the `PrometheusMiddleware` to an application, however, I am seeing some strange behavior when starting the worker(s). `taskiq` version: 0.8.2...
The log here, I think it should be that if found_exception is not None, the value of log is equal to str(exc). If the operation is normal, do you need...
We need to provide more control over task execution. Currently we need to add Cancel error, to be able to implement scenario, described in #132.
Should help with #63 "Works on my machine" (c), but I have a somewhat unusual setup and I don't have enough knowledge of the project to properly test this (I've...
Hi! Thank you for to simple and easy to use tasks manager lib! Please help me to understand, how to achieve graceful reload? Can't find any docs about this. **How...
Hello. Is it possible to add functionality so i could run missed tasks if scheduler was restarted? For example, task runs every 10 hours. After some amount of time when...
I create singleton middleware. It checks whether such a task already exists and, if so, should cancel its sending in the pre_send func. How to do it correctly? Return None...
I would like to know precisely how max_prefetch works. If I set workers = 6, for example, thus six worker processes, and I do not set max_prefetch, how will the...