Function _shutdown_resources

api_utils/app.py:175–262

()

async def _shutdown_resources():
    logger = state.logger
    logger.info("Shutting down resources...")

    # Signal global shutdown if event exists
    try:
        from config import GlobalState

        if hasattr(GlobalState, "IS_SHUTTING_DOWN") and hasattr(
            GlobalState.IS_SHUTTING_DOWN, "set"
        ):
            GlobalState.IS_SHUTTING_DOWN.set()
    except Exception as e:
        logger.debug(f"Failed to set IS_SHUTTING_DOWN: {e}")

    state.should_exit = True

    if state.STREAM_PROCESS:
        try:
            state.STREAM_PROCESS.terminate()
            state.STREAM_PROCESS.join(timeout=3)
            if state.STREAM_PROCESS.is_alive():
                logger.warning("STREAM proxy did not terminate, killing...")
                state.STREAM_PROCESS.kill()
                state.STREAM_PROCESS.join(timeout=1)
        except Exception as e:
            logger.error(f"Error terminating STREAM proxy: {e}")
        finally:
            if state.STREAM_QUEUE:
                try:
                    state.STREAM_QUEUE.close()
                    state.STREAM_QUEUE.join_thread()
                except Exception:
                    pass
            state.STREAM_PROCESS = None
            state.STREAM_QUEUE = None
            logger.info("STREAM proxy terminated.")

    if state.worker_task and not state.worker_task.done():
        logger.info("Cancelling worker task...")
        state.worker_task.cancel()
        try:
            await asyncio.wait_for(state.worker_task, timeout=2.0)
            logger.info("Worker task cancelled.")
        except asyncio.TimeoutError:
            logger.warning("Worker task did not respond to cancellation within 2s.")
        except asyncio.CancelledError:
            logger.debug("Worker task cancellation acknowledged (CancelledError).")
        except Exception as e:
            logger.error(f"Error cancelling worker task: {e}")
        finally:
            state.worker_task = None

    if state.page_instance:
        try:
            await _close_page_logic()
        except asyncio.CancelledError:
            logger.debug("Page closure cancelled (CancelledError).")