[Iamsdt]

Background tasks on TaskIQ

Adds durable background tasks to 10xgraph-api as a thin layer over TaskIQ: we own one broker, wire monitoring, auth and the run config, and add worker / scheduler commands and HTTP routes. TaskIQ does the queueing, retries, results and scheduling.

Developer API

from typing import Annotated
from taskiq import TaskiqDepends
from tenxgraph_api.jobs import broker, TaskContext

@broker.task(task_name="make_report", http=True)
async def make_report(topic: str, config: dict, ctx: Annotated[TaskContext, TaskiqDepends()]) -> dict:
    if await ctx.cancelled():
        return {"cancelled": True}
    return {"topic": topic, "user_id": config["user_id"]}

[codecov]

Codecov Report

✅ All modified and coverable lines are covered by tests.

📢 Thoughts on this report? Let us know!