INNER CODE UNIT · Python

_build_runner

416rehman/DeepZero · src/deepzero/cli.py:130

def _build_runner(pipeline_def: Any, dashboard: Any = None) -> tuple[Any, Any]:
    # shared setup for run/resume - builds PipelineRunner and optional LLM provider
    from deepzero.engine.llm import LLMProvider
    from deepzero.engine.runner import PipelineRunner
    from deepzero.engine.state import StateStore

    llm = LLMProvider(pipeline_def.model) if pipeline_def.model else None

    state_store = StateStore(pipeline_def.work_dir)

    runner = PipelineRunner(
        ingest=pipeline_def.ingest_processor,
        stages=pipeline_def.stages,
        state_store=state_store,
        pipeline_dir=pipeline_def.pipeline_dir,
        global_config=pipeline_def.to_global_config(),
        llm=llm,
        default_max_workers=pipeline_def.max_workers,

View source record →