Struct SequentialScheduler 

pub struct SequentialScheduler;

Implementations

impl SequentialScheduler

pub fn execute_phase( &self, plan: &ExecutionPlan, controllers: &RuntimeControllerRegistry, ctx: &mut RunContext, phase: Phase, ) -> Result<Vec<NodeResult>, DagMlError>

pub fn execute_phase_with_data_provider( &self, plan: &ExecutionPlan, controllers: &RuntimeControllerRegistry, data_provider: &dyn RuntimeDataProvider, ctx: &mut RunContext, phase: Phase, ) -> Result<Vec<NodeResult>, DagMlError>

pub fn execute_campaign_phase( &self, plan: &ExecutionPlan, controllers: &RuntimeControllerRegistry, ctx: &mut RunContext, phase: Phase, ) -> Result<Vec<NodeResult>, DagMlError>

pub fn execute_campaign_phase_with_data_provider( &self, plan: &ExecutionPlan, controllers: &RuntimeControllerRegistry, data_provider: &dyn RuntimeDataProvider, ctx: &mut RunContext, phase: Phase, ) -> Result<Vec<NodeResult>, DagMlError>

pub fn execute_campaign_phase_with_data_provider_and_artifact_store( &self, plan: &ExecutionPlan, controllers: &RuntimeControllerRegistry, data_provider: &dyn RuntimeDataProvider, artifact_store: &mut InMemoryArtifactStore, ctx: &mut RunContext, phase: Phase, ) -> Result<Vec<NodeResult>, DagMlError>

pub fn execute_bundle_replay( &self, replay: BundleReplayExecution<'_>, ctx: &mut RunContext, ) -> Result<Vec<NodeResult>, DagMlError>

Trait Implementations

impl Clone for SequentialScheduler

fn clone(&self) -> SequentialScheduler

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SequentialScheduler

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for SequentialScheduler

fn default() -> SequentialScheduler

Returns the “default value” for a type.