taskiq
taskiq copied to clipboard
taskiq-python
Distributed task queue with full async support
Asynchronous ZeroMQ does not work on **Windows** with default `asyncio.WindowsProactorEventLoopPolicy`. It raises: ``` RuntimeError: Proactor event loop does not implement add_reader family of methods required for zmq. zmq will work...
## Description I removed socket.connect because it's not needed for bind, as bind is used for connecting. And I added unbind for broker shutdown. We can see it in this...
Middleware has hooks before task execution and after task execution. The order these hooks run in is dependent on the order they are placed on the broker. Lets take an...
Hello! The README of the project says: > But taskiq can **send** and run both the sync and async functions I can see some docs about running sync functions as...
I noticed that the Prometheus middleware doesn't work with the scheduler, is this intentional or is this something that can be implemented?
I am running my taskiq worker as:- `poetry run taskiq worker src.jobs.broker:broker src.jobs -w 1 --no-configure-logging` my broker configuration ``` """TaskIQ broker configuration with PostgreSQL backend.""" import logging from taskiq...
# Description 💡 It could be great if we could get the *last scheduled tasks* results. Let's say I trigger a new cron task. - If I try to execute...
Today if we call `schedule_by_cron` with our task arguments we can't use `source` or `cron` arguments names as they are already used by `schedule_by_cron` itself. Maybe it would be cleaner...
First, I'd like to thank the author and all contributors for creating and maintaining this great library. I encountered an issue while deserializing Pydantic models with aliased fields from task...
Metadata
Owner
Metadata
Distributed task queue with full async support