[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

❌ Patch coverage is 85.22848% with 139 lines in your changes missing coverage. Please review.

Files with missing lines	Patch %	Lines
tenxgraph_api/jobs/redis_broker.py	27.63%	55 Missing ⚠️
tenxgraph_api/src/app/routers/tasks/router.py	87.67%	14 Missing and 4 partials ⚠️
tenxgraph_api/src/app/routers/tasks/boot.py	59.25%	11 Missing ⚠️
tenxgraph_api/jobs/worker.py	84.12%	6 Missing and 4 partials ⚠️
tenxgraph_api/src/app/main.py	0.00%	7 Missing and 2 partials ⚠️
tenxgraph_api/cli/main.py	46.66%	8 Missing ⚠️
tenxgraph_api/cli/commands/worker.py	91.42%	5 Missing and 1 partial ⚠️
tenxgraph_api/jobs/middleware.py	93.02%	3 Missing and 3 partials ⚠️
tenxgraph_api/jobs/arguments.py	88.37%	4 Missing and 1 partial ⚠️
...xgraph_api/src/app/core/config/setup_middleware.py	92.30%	3 Missing ⚠️
... and 4 more

📢 Thoughts on this report? Let us know!