Function _runner

tools/app_runner.py:61–107

()

            pass

    async def _runner() -> None:
        loop = asyncio.get_running_loop()
        runner_task = asyncio.current_task()
        if runner_task is None:
            raise RuntimeError("Runner task not found")

        shutdown_requested = False

        def _on_signal(signum: int) -> None:
            nonlocal shutdown_requested

            if shutdown_requested:
                print("[Main] Received interrupt signal again, force exit.")
                os._exit(force_exit_code)

            shutdown_requested = True
            print(f"\n[Main] Received interrupt signal {signum}, exiting (cleanup max {cleanup_timeout_seconds}s)...")

            if on_first_interrupt is not None:
                try:
                    on_first_interrupt()
                except Exception:
                    pass

            runner_task.cancel()

        try:
            loop.add_signal_handler(signal.SIGINT, _on_signal, signal.SIGINT)
            loop.add_signal_handler(signal.SIGTERM, _on_signal, signal.SIGTERM)
        except NotImplementedError:
            signal.signal(signal.SIGINT, lambda signum, _frame: _on_signal(signum))
            signal.signal(signal.SIGTERM, lambda signum, _frame: _on_signal(signum))

        cancelled = False
        try:
            await app_main()
        except asyncio.CancelledError:
            cancelled = True
        finally:
            try:
                await _cleanup_with_timeout()
            except Exception as e:
                print(f"[Main] Error during cleanup: {e}")
            await _cancel_remaining_tasks()

        if cancelled:
            return

    asyncio.run(_runner())