Struct ParallelScheduler 

pub struct ParallelScheduler { /* private fields */ }

Implementations

impl ParallelScheduler

pub fn new(max_workers: usize) -> Result<ParallelScheduler, DagMlError>

pub fn max_workers(&self) -> usize

impl ParallelScheduler

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 ParallelScheduler

fn clone(&self) -> ParallelScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelScheduler

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

Formats the value using the given formatter.