Struct ExecutionPlan 

pub struct ExecutionPlan {
    pub id: String,
    pub graph_plan: GraphPlan,
    pub campaign: CampaignSpec,
    pub node_plans: BTreeMap<NodeId, NodePlan>,
    pub controller_manifests: BTreeMap<ControllerId, ControllerManifest>,
    pub variants: Vec<VariantPlan>,
    pub fold_set: Option<FoldSet>,
    pub graph_fingerprint: String,
    pub campaign_fingerprint: String,
    pub controller_fingerprint: String,
}

Fields

id: String

graph_plan: GraphPlan

campaign: CampaignSpec

node_plans: BTreeMap<NodeId, NodePlan>

controller_manifests: BTreeMap<ControllerId, ControllerManifest>

variants: Vec<VariantPlan>

fold_set: Option<FoldSet>

graph_fingerprint: String

campaign_fingerprint: String

controller_fingerprint: String

Implementations

impl ExecutionPlan

pub fn validate(&self) -> Result<(), DagMlError>

pub fn validate_parallel_controller_capabilities( &self, max_workers: usize, phase: Phase, ) -> Result<(), DagMlError>

pub fn node_parallel_levels_for_phase( &self, phase: Phase, ) -> Result<Vec<Vec<NodeId>>, DagMlError>

pub fn campaign_phase_schedule( &self, phase: Phase, ) -> Result<PhaseExecutionSchedule, DagMlError>

pub fn branch_view_for(&self, branch_id: &str) -> Option<&BranchViewPlan>

Returns the BranchViewPlan whose branch_id matches branch_id, if any. The match is exact; callers that need fuzzy or prefix matching must iterate self.campaign.branch_view_plans themselves.

pub fn branch_view_for_path( &self, branch_path: &[String], ) -> Option<&BranchViewPlan>

Returns the BranchViewPlan for the deepest branch in branch_path that has a matching plan, if any. The path is walked tip-first so the closest enclosing branch wins; an empty path returns None. The returned reference borrows the plan from the campaign; the caller can .clone() it into a DataProviderViewSpec.branch_view field when constructing a provider view for an in-branch node.

Trait Implementations

impl Clone for ExecutionPlan

fn clone(&self) -> ExecutionPlan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionPlan

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExecutionPlan

fn deserialize<__D>( __deserializer: __D, ) -> Result<ExecutionPlan, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ExecutionPlan

fn eq(&self, other: &ExecutionPlan) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ExecutionPlan

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ExecutionPlan