taskiq
taskiq copied to clipboard
Distributed task queue with full async support
I couldn't find any plugin/extension for an AWS SQS Broker for TaskIQ, so I was thinking of creating one. Any feedback or suggestions?
This proposed solution addresses an issue encountered when attempting to utilize acknowledgment functionality. Currently, the `Receiver` module contains two types of messages: `AckableMessage` originating from the broker, which includes an...
### Updates 1) Per-second main event loop cycle; 2) ScheduledTask.period field is added; 3) Periodic tasks execution feature has been added. ### Design ways 1. The current approach with iterating...
Thank you so much for creating such a cool library, but I found a problem. rabbitmq has support for dead messages, and taskiq-aio-pika even creates a queue for them. But...
Hello, Currently, the scheduler is run every minutes. If I want to delay by seconds, it wil wait the next minute (in my usecase it's not what I want). I...
properly created PR instead of https://github.com/taskiq-python/taskiq/pull/121
Currently using `--reload` argument will take into account `.gitignore`, but there are files that will trigger a reload even when it isn't necessary. These files must be in the repo...
Added loading logging config from ini, json, yaml files.
Hello, I have a special case to manage and I don't see how to do it. At a given moment, I need to know if a task (I have its...
Hello, After scheduler restart all cron scheduled tasks are getting duplicated... Should we remove all scheduled tasks on scheduler startup like in code bellow? Right now only time (not cron)...