Struct Runner 

pub struct Runner<S: CheckpointStore> { /* private fields */ }

Runner - executes agents/graphs with abort, pause, and event streaming

Implementations

impl<S: CheckpointStore> Runner<S>

pub fn new(checkpoint_store: Arc<S>) -> Self

Create a new runner

pub fn execution_id(&self) -> &ExecutionId

Get the execution ID

pub fn emitter(&self) -> &EventEmitter

Get the event emitter

pub fn cancel(&self)

Cancel the run (abort signal)

pub fn is_cancelled(&self) -> bool

Check if cancelled

pub async fn pause(&self) -> Result<()>

Pause the run

pub fn resume(&self)

Resume the run

pub fn is_paused(&self) -> bool

Check if paused

pub async fn save_checkpoint( &self, state: NodeState, node: Option<&str>, agent_name: Option<&str>, ) -> Result<Checkpoint>

Save checkpoint

Arguments

• state - The current node state to save
• node - Optional current node name
• agent_name - Optional agent name for restoration on resume

pub async fn load_checkpoint(&self) -> Result<Option<Checkpoint>>

Load latest checkpoint

pub async fn run_callable<A: Callable + ?Sized>( &mut self, callable: &A, input: &str, ) -> Result<String>

Run a callable with event streaming

pub async fn run_graph( &mut self, graph: &CompiledGraph, input: &str, ) -> Result<NodeState>

Run a compiled graph with event streaming

impl Runner<InMemoryCheckpointStore>

pub fn default_new() -> Self

Create a new runner with in-memory checkpoint store