Struct GraphExecutor 

pub struct GraphExecutor<State, Deps, End, P = NoPersistence>
where
    State: GraphState,
{ /* private fields */ }

Graph executor with optional persistence and instrumentation.

Implementations

impl<State, Deps, End> GraphExecutor<State, Deps, End, NoPersistence>

where State: GraphState, Deps: Clone + Send + Sync + 'static, End: Clone + Send + Sync + 'static,

pub fn new(graph: Graph<State, Deps, End>) -> Self

Create a new executor without persistence.

impl<State, Deps, End, P> GraphExecutor<State, Deps, End, P>

where State: GraphState, Deps: Clone + Send + Sync + 'static, End: Clone + Send + Sync + 'static, P: StatePersistence<State, End> + 'static,

pub fn with_persistence(graph: Graph<State, Deps, End>, persistence: P) -> Self

Create an executor with persistence.

pub fn auto_save(self, enabled: bool) -> Self

Set whether to automatically save state.

pub fn max_steps(self, max: u32) -> Self

Set maximum steps.

pub fn without_instrumentation(self) -> Self

Disable instrumentation.

pub fn graph(&self) -> &Graph<State, Deps, End>

Get a reference to the graph.

pub async fn run( &self, state: State, deps: Deps, ) -> GraphResult<GraphRunResult<State, End>>

Run the graph.

pub async fn run_with_options( &self, state: State, deps: Deps, options: ExecutionOptions, ) -> GraphResult<GraphRunResult<State, End>>

Run the graph with options.

pub async fn resume( &self, run_id: &str, deps: Deps, ) -> GraphResult<Option<GraphRunResult<State, End>>>

Resume a previous run.

pub async fn get_result(&self, run_id: &str) -> GraphResult<Option<End>>

Get a saved result.

pub async fn list_runs(&self) -> GraphResult<Vec<String>>

List all saved runs.