INNER CODE UNIT · Python

remaining

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

        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,
                    exc_info=(type(result), result, result.__traceback__),
                )
            elif result is False:
                clean_pass = False

View source record →