ri-agent-graph 0.2.2

Graph-based agent orchestration for Rust — LangGraph-inspired execution engine with checkpointing, parallel fan-out/fan-in, interrupt/resume, and event streaming
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use serde::{Deserialize, Serialize};

/// Exact position of an interrupted execution.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct ExecutionCursor {
    pub iteration: usize,
    pub step_number: usize,
    pub interrupt_phase: InterruptPhase,
    pub resume_boundary: String,
    pub active_nodes: Vec<String>,
    pub remaining_nodes: Vec<String>,
    pub completed_nodes_in_superstep: Vec<String>,
    pub graph_version: String,
    pub state_digest: String,
}

#[derive(Debug, Clone, Copy, Serialize, Deserialize, PartialEq, Eq)]
pub enum InterruptPhase {
    Before,
    After,
}