Async job queue for Python with Redis, PostgreSQL, and MySQL backends, priority queues, job dependencies, dead letter queues, and a built-in real-time dashboard.
pip install aioq # Redis only
pip install "aioq[postgres]" # + PostgreSQL
pip install "aioq[mysql]" # + MySQL
pip install "aioq[all]" # everything# tasks.py
from aioq import Aarq
from aioq.backends import RedisBroker
app = Aarq(broker=RedisBroker(url="redis://localhost:6379"))
@app.task(queue="default", retries=3)
async def my_task(ctx, value: int):
...aioq worker tasks:app # run a worker
aioq dashboard tasks:app # dashboard at :8080See the docs for full usage.
MIT