pipeline

module wittgenstein_pipelines.pipeline

Classes

• PipelineRunner — Orchestrates sequential and conditional execution of registered pipeline/workflow steps.

wittgenstein_pipelines.pipeline.PipelineRunner

class PipelineRunner(steps: List[PipelineStep])

Orchestrates sequential and conditional execution of registered pipeline/workflow steps.

Methods

• register_step_executor — Register the executable function for a given step ID.

• run — Run all steps sequentially respecting dependencies.

wittgenstein_pipelines.pipeline.PipelineRunner.register_step_executor

method PipelineRunner.register_step_executor(step_id: str, fn: Callable[[PipelineContext], Any]) → None

Register the executable function for a given step ID.

Raises

• ValueError

wittgenstein_pipelines.pipeline.PipelineRunner.run

async method PipelineRunner.run(self, context: PipelineContext) → PipelineContext

Run all steps sequentially respecting dependencies.

Raises

• RuntimeError