Enum DistributedExecutionPhase 

#[non_exhaustive]
pub enum DistributedExecutionPhase {
    StateCheckpoint,
    PromptCacheLoadPreflight,
    PromptCacheLoadPreparation,
    PromptCacheSavePreflight,
    PromptCacheSavePreparation,
    PromptCacheSavePublication,
    SessionCheckpoint,
    SessionResetPreparation,
    SessionRollbackPreparation,
    BoundarySourceCompletion(CommunicationRouteId),
    BoundarySourceReady(CommunicationRouteId),
    Execution,
    OutputObservation,
    PredictionTargetCapture,
    PredictionTargetCapturePublication,
    PredictionTargetStatePreparation,
    PredictionExtensionExecution,
    OutputPublication,
    SamplingSynchronization,
    MechanismCompletion,
    Commit,
}

Canonical shared-session phases whose local status must be propagated.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

StateCheckpoint

Every rank captured the state checkpoint required for transactional rollback.

PromptCacheLoadPreflight

Every rank accepted the exact prompt-cache load identity and input.

PromptCacheLoadPreparation

Every stateful rank loaded and validated a provisional cache shard.

PromptCacheSavePreflight

Every rank accepted the exact prompt-cache save identity and input.

PromptCacheSavePreparation

Every stateful rank serialized and validated an unpublished cache shard.

PromptCacheSavePublication

Every stateful rank reversibly published its prepared cache shard.

SessionCheckpoint

Every stateful rank captured an opaque manual-control checkpoint.

SessionResetPreparation

Every stateful rank prepared a replacement selected state.

SessionRollbackPreparation

Every stateful rank restored a checkpoint into provisional state.

BoundarySourceCompletion(CommunicationRouteId)

Source tensor dependencies reached exact bounded completion for one route.

BoundarySourceReady(CommunicationRouteId)

Source execution and both endpoint preparations completed for one route.

Execution

Rank-local graph execution, including boundary transfer and publication.

OutputObservation

Final output observation and intervention.

PredictionTargetCapture

Output-owner hidden capture is present and published for prediction.

PredictionTargetCapturePublication

Every rank completed publication of the exact prediction target capture.

PredictionTargetStatePreparation

Every rank validated a provisional prediction-lane target state swap.

PredictionExtensionExecution

Every rank completed one typed prediction-only unit operation.

OutputPublication

Publication of the authoritative intervened output to every rank.

SamplingSynchronization

Publication of the authoritative sampled token and stop status.

MechanismCompletion

Exact output and mutable-state mechanism completion.

Commit

Final distributed state-commit decision.

Trait Implementations

impl Clone for DistributedExecutionPhase

fn clone(&self) -> DistributedExecutionPhase

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for DistributedExecutionPhase

impl Debug for DistributedExecutionPhase

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

Formats the value using the given formatter.

impl Eq for DistributedExecutionPhase

impl PartialEq for DistributedExecutionPhase

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for DistributedExecutionPhase