Struct GraphExecution 

pub struct GraphExecution<S: StateSchema> {
    pub state: S,
    pub current_node: String,
    pub steps: Vec<ExecutionStep>,
    pub recursion_count: usize,
    pub interrupted_at: String,
}

GraphExecution - State for interrupted execution that can be resumed

Fields

state: S

The state at the point of interruption.

current_node: String

The node where execution was interrupted.

steps: Vec<ExecutionStep>

Execution steps recorded so far.

recursion_count: usize

Recursion budget consumed up to the interruption.

interrupted_at: String

Where execution was interrupted (“node” or “after_node”).

Implementations

impl<S: StateSchema> GraphExecution<S>

pub fn new( state: S, current_node: impl Into<String>, interrupted_at: impl Into<String>, ) -> Self

Create a new execution context for resuming from an interruption.

pub fn state(&self) -> &S

Return the current state.

pub fn interrupted_at(&self) -> &str

Return the interruption point.

Trait Implementations

impl<S: Clone + StateSchema> Clone for GraphExecution<S>

fn clone(&self) -> GraphExecution<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug + StateSchema> Debug for GraphExecution<S>

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

Formats the value using the given formatter.