Function data_stats

examples/celery_alternative/app.py:343–350

Get data worker statistics.

()

@app.get("/api/data/stats")
async def data_stats():
    """Get data worker statistics."""
    try:
        client = await get_dirty_client_async()
        result = await client.execute_async(DATA_WORKER, "stats")
        return result
    except DirtyError as e:
        raise HTTPException(status_code=500, detail=str(e))


# ============================================================================