Struct NodeTask 

pub struct NodeTask {

    pub run_id: RunId,
    pub node_plan: NodePlan,
    pub phase: Phase,
    pub variant_id: Option<VariantId>,
    pub variant: Option<VariantExecutionSpec>,
    pub fold_id: Option<FoldId>,
    pub branch_path: Vec<BranchId>,
    pub input_handles: BTreeMap<String, HandleRef>,
    pub data_views: BTreeMap<String, DataProviderViewSpec>,
    pub prediction_inputs: BTreeMap<String, PredictionInputSpec>,
    pub artifact_inputs: BTreeMap<String, ArtifactInputSpec>,
    pub required_loss_attestations: Vec<LossExecutionAttestation>,
    pub inner_fold_set: Option<FoldSet>,
    pub fit_influence: FitInfluenceTask,
    pub seed: Option<u64>,
}

Fields

run_id: RunId

node_plan: NodePlan

phase: Phase

variant_id: Option<VariantId>

variant: Option<VariantExecutionSpec>

fold_id: Option<FoldId>

branch_path: Vec<BranchId>

input_handles: BTreeMap<String, HandleRef>

data_views: BTreeMap<String, DataProviderViewSpec>

prediction_inputs: BTreeMap<String, PredictionInputSpec>

artifact_inputs: BTreeMap<String, ArtifactInputSpec>

required_loss_attestations: Vec<LossExecutionAttestation>

Native-produced attestation templates for the training losses that must execute in this task. The order matches node_plan.training_losses after filtering for phase. A controller may copy an entry into its lineage only after the corresponding local or built-in loss succeeds.

inner_fold_set: Option<FoldSet>

Nested (inner) CV fold set for this node in the current outer fold, built by the runtime from the outer fold’s training samples when an effective inner_cv policy applies (FIT_CV only). None otherwise. Leakage-safe by construction (inner ⊆ outer-train); see crate::fold::NestedCvSpec.

fit_influence: FitInfluenceTask

seed: Option<u64>

Implementations

impl NodeTask

pub fn required_loss_attestations_for( node_plan: &NodePlan, phase: Phase, ) -> Result<Vec<LossExecutionAttestation>>

pub fn validate_required_loss_attestations(&self) -> Result<()>

pub fn training_loss_binding( &self, role_index: usize, ) -> Result<(&TrainingLossRoleReference, &LossExecutionAttestation)>

Return one active training-loss role and its exact native attestation.

The index addresses losses after filtering the node plan for the task’s phase. This keeps host bindings from reconstructing role ordering or trusting controller-supplied attestation fields.

Trait Implementations

impl Clone for NodeTask

fn clone(&self) -> NodeTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeTask

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeTask

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for NodeTask

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for NodeTask

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for NodeTask