INNER CODE UNIT · Python

deadline

Soju06/codex-lb · app/main.py:310

    deadline = loop.time() + timeout_seconds
    clean_passes = 0

    while clean_passes < 2:
        remaining = max(0.0, deadline - loop.time())
        results = await asyncio.gather(
            drain_audit_log_tasks(remaining),
            fleet_api.drain_background_refresh_tasks(remaining),
            return_exceptions=True,
        )

        clean_pass = True
        for task_kind, result in zip(("audit log", "fleet refresh"), results, strict=True):
            if isinstance(result, BaseException):
                clean_pass = False
                logger.warning(
                    "Failed to drain %s tasks during shutdown",
                    task_kind,

View source record →