Struct PipelineRunner 

pub struct PipelineRunner {
    pub handler_registry: HandlerRegistry,
    pub interviewer: Box<dyn Interviewer>,
    pub event_tx: Option<Sender<PipelineEvent>>,
}

The pipeline execution engine.

Fields

handler_registry: HandlerRegistry

interviewer: Box<dyn Interviewer>

event_tx: Option<Sender<PipelineEvent>>

Implementations

impl PipelineRunner

pub fn new( handler_registry: HandlerRegistry, interviewer: Box<dyn Interviewer>, ) -> Self

Create a new PipelineRunner.

pub fn with_events(self, tx: Sender<PipelineEvent>) -> Self

Set the event channel for observability.

pub async fn run( &self, graph: &PipelineGraph, context: &PipelineContext, run_dir: &RunDirectory, checkpoint: Option<Checkpoint>, ) -> Result<StageStatus>

Execute a pipeline graph from start to finish.