Struct PipelineExecutor 

pub struct PipelineExecutor { /* private fields */ }

Pipeline executor

Implementations

impl PipelineExecutor

pub fn from_pipeline(pipeline: &Pipeline) -> Result<Self, GraphError>

Create a new executor from a pipeline

pub fn new(graph: ExecutionGraph) -> Self

Create a new executor from an execution graph

pub fn with_config(self, config: ExecutorConfig) -> Self

Set executor configuration

pub fn with_progress(self, tx: ProgressSender) -> Self

Set progress event sender

pub fn with_task_runner(self, cache_dir: PathBuf) -> Self

Enable task execution with the specified cache directory

pub fn with_container_runner(self) -> Self

Enable container execution

pub async fn execute(&self, context: ExecutionContext) -> ExecutionResult

Execute the pipeline