INNER CODE UNIT · Python

deadline

caipe-io/ai-platform-engineering · ai_platform_engineering/audit_service/main.py:74

    deadline = asyncio.get_running_loop().time() + timeout_seconds
    try:
        while True:
            done, _ = await asyncio.wait({task}, timeout=0.1)
            if done:
                return task.result()
            if await request.is_disconnected():
                raise HTTPException(status_code=499, detail="audit read client disconnected")
            if asyncio.get_running_loop().time() >= deadline:
                raise HTTPException(status_code=504, detail="audit read timed out; use a shorter time range")
    except AuditQueryCancelled as exc:
        raise HTTPException(status_code=499, detail="audit read cancelled") from exc
    finally:
        cancel_event.set()


async def _purge_local_retention(store: LocalAuditStore, retention_days: int) -> None:
    try:

View source record →