taskiq
taskiq copied to clipboard
taskiq-python
Distributed task queue with full async support
I'm seeing the issue mentioned in #229 still in 0.10.4. Tested with taskiq 0.10.4, taskiq-redis 0.5.5, and python 3.8.15. Also tested with taskiq 0.10.2. The strange thing is that this...
Hello In run_scheduler_loop function in next_minute calculation if datetime.now() = 17:22:59.55555 and we replace seconds and microseconds with 0 and add timedelta(minutes=1) we get next_minute=17:23:00 and when we calculate delay...
Is it possible to get the `--reload` arg on the scheduler too, with similar functionality to the worker?
Sometimes we fall into state, when taskiq worker hangs and doesn't react to signals like SIGTERM. We need to fix it, since it's really annoying. Maybe we should differently work...
Hello and thank you very much for your work on this project. I currently have an issue where tasks submitted with custom labels mutates the underlying decorated task instance ```python...
It's common practice to add perform healtchecks inside containers in dockerized environment. If healthcheck fails do pass within defined parameters, docker daemon restarts the container. HTTP / uwsgi process usually...
The `InMemoryBroker` bundled in taskiq does not call `startup()` on its `result_backend`. The default `result_backend` for `InMemoryBroker` (`InmemoryResultBackend`) does not implement `startup()` so if you do not override the `result_backend`...
Hello! I need the ability to run tasks at intervals shorter than one minute. Currently, the scheduler seems to run tasks every minute, often with some delays. Are there examples...
The documentation for [Kicker](https://taskiq-python.github.io/guide/architecture-overview.html#kicker) shows `.with_labels(delay=1)`: ```python async def main(): # This task was initially assigned to broker, # but this time it is going to be sent using #...
Metadata
Owner
Metadata
Distributed task queue with full async support