Function cached_query

examples/celery_alternative/app.py:327–339

Execute a cached query.

(data: QueryRequest)

@app.post("/api/data/query")
async def cached_query(data: QueryRequest):
    """Execute a cached query."""
    try:
        client = await get_dirty_client_async()
        result = await client.execute_async(
            DATA_WORKER,
            "cached_query",
            query_key=data.query_key,
            ttl=data.ttl,
        )
        return result
    except DirtyError as e:
        raise HTTPException(status_code=500, detail=str(e))


@app.get("/api/data/stats")