INNER CODE UNIT · Python

_stop_stream_manager

roboflow/inference · inference_server/inference_server/app.py:205

def _stop_stream_manager(process: Any) -> None:
    process.terminate()
    process.join(STREAM_MANAGER_STOP_TIMEOUT_S)
    if not process.is_alive():
        return None

    logger.warning(
        "The stream manager process did not stop within %s s; killing it",
        STREAM_MANAGER_STOP_TIMEOUT_S,
    )
    process.kill()
    process.join(STREAM_MANAGER_STOP_TIMEOUT_S)

    return None


def _warn_if_stream_manager_died(process: Any) -> None:
    if process.is_alive():

View source record →