Enum DurabilityMode 

pub enum DurabilityMode {
    Sync,
    Async,
    Exit,
}

When committed checkpoints are persisted relative to graph execution.

The default is DurabilityMode::Sync, which preserves today’s behavior.

Variants

Sync

Persist a checkpoint before the next step starts. The boundary state is durable before any successor node runs — the strongest guarantee.

Async

Persist off the critical path: the boundary checkpoint write is handed to a spawned background task while the next step executes, so superstep latency does not pay for checkpoint I/O.

Failure semantics: a background write error is not silently lost. The executor records it and fails the run at the next durability boundary that observes it; at the terminal boundary (and at any interrupt boundary) every in-flight write is awaited, so a completed run’s result always reflects its checkpoints’ persistence. The final (terminal) and interrupt checkpoints themselves are always written synchronously. The CheckpointSaved event for a background write is emitted when the write completes, so its ordering relative to later step events is not deterministic. Outside a tokio runtime this mode degrades to DurabilityMode::Sync.

Exit

Persist only the final checkpoint when the graph exits (or pauses on an interrupt). Intermediate boundaries are not written, trading resumability granularity for fewer writes.

Trait Implementations

impl Clone for DurabilityMode

fn clone(&self) -> DurabilityMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for DurabilityMode

impl Debug for DurabilityMode

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

Formats the value using the given formatter.

impl Default for DurabilityMode

fn default() -> DurabilityMode

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for DurabilityMode

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for DurabilityMode

impl PartialEq for DurabilityMode

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for DurabilityMode

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 DurabilityMode