Struct RobustPipelineExecutor 

pub struct RobustPipelineExecutor { /* private fields */ }

Robust pipeline execution with error recovery

Implementations

impl RobustPipelineExecutor

pub fn new() -> Self

Create a new robust pipeline executor

pub fn max_retries(self, retries: usize) -> Self

Set maximum retries

pub fn fallback_strategy(self, strategy: FallbackStrategy) -> Self

Set fallback strategy

pub fn error_handling(self, strategy: ErrorHandlingStrategy) -> Self

Set error handling strategy

pub fn timeout_seconds(self, timeout: u64) -> Self

Set timeout

pub fn execute<S>( &self, pipeline: Pipeline<S>, x: &ArrayView2<'_, Float>, y: Option<&ArrayView1<'_, Float>>, ) -> SklResult<Array1<f64>>

where S: Debug,

Execute pipeline with robust error handling

Trait Implementations

impl Default for RobustPipelineExecutor

fn default() -> Self

Returns the “default value” for a type.