taskiq
taskiq copied to clipboard
taskiq-python
Distributed task queue with full async support
Gist with example implementation: https://gist.github.com/cofob/6b89f4d62efb4eddb26a3c8853128c84 I'm not sure how to integrate this into the taskiq codebase, as you need to configure the logging handler in some way, and you need...
Registers the prometheus metrics with a CollectorRegistry as specified by the prometheus-client docs: https://github.com/prometheus/client_python/blob/master/README.md#multiprocess-mode-eg-gunicorn I also notice that the documentation explicitly says to not overwrite `PROMETHEUS_MULTIPROC_DIR` which is being done...
As far as I know, current design of scheduler works like this: 1. send all tasks that are scheduled to current minute 2. wait until next minute start (while asynchronously...
Minor feature request In Celery possible to get Master worker PID by option --pidfile=/tmp/my_file_with_pid would be perfect to get leader worker pid in Taskiq as well.
Good afternoon! I have such a problem: there is a function, it puts a task in the scheduler for execution on time: ``` python async def register_mailing(self, mailing_id: str, group_id:...
Add middleware, which will allow to use various functions to determine the delay time before sending
I used to run the `taskiq worker ...` with [`ddtrace-run`](https://ddtrace.readthedocs.io/en/stable/) (i.e. `ddtrace-run taskiq worker ...`) but this is raising an error now: ``` Traceback (most recent call last): File "/Users/murilositonio/.pyenv/versions/remediation-automation-api-3.11/bin/taskiq",...
Hello! I need to run tasks on specific nodes from the main application, how can this be implemented? For example this kind of worker code: ```python @broker.task def example_task(node_name: str):...
**Operating System: Windows 11 Python: 3.11.4 poetry: 1.5.1 taskiq: 0.8.4 taskiq-nats: 0.3.0** **Hello 👋** Decided to upgrade taskiq `0.8.2` ~> `0.8.4`, when I try to run the script broker or...
Metadata
Owner
Metadata
Distributed task queue with full async support