Function run_pipeline

agent/src/opentrace_agent/pipeline/pipeline.py:67–78

Public entry point — run the full pipeline, optionally persisting via store.

(
    inp: PipelineInput,
    ctx: PipelineContext | None = None,
    store: Store | None = None,
)

def run_pipeline(
    inp: PipelineInput,
    ctx: PipelineContext | None = None,
    store: Store | None = None,
) -> Generator[PipelineEvent, None, None]:
    """Public entry point — run the full pipeline, optionally persisting via store."""
    ctx = ctx or PipelineContext()
    inner = core_pipeline(inp, ctx)
    if store is not None:
        yield from saving(inner, store)
    else:
        yield from inner


def collect_pipeline(