INNER CODE UNIT · Python

_start_stream_manager

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

def _start_stream_manager(
    streams_configuration: Any,
    *,
    host_descriptor: Any,
    expected_warmed_up_pipelines: int,
) -> multiprocessing.Process:
    from streamvision.stream_manager.manager_app.bootstrap import run_stream_manager

    process = multiprocessing.get_context("spawn").Process(
        target=partial(
            run_stream_manager,
            configuration=streams_configuration,
            host_descriptor=host_descriptor,
            expected_warmed_up_pipelines=expected_warmed_up_pipelines,
        ),
        name="stream-manager",
    )
    process.start()

View source record →