Struct ExecutableGraph 

pub struct ExecutableGraph<S: StateSchema> { /* private fields */ }

Implementations

impl<S: StateSchema<Update = S>> ExecutableGraph<S>

pub async fn invoke_graph( &self, state: GraphState<S>, ) -> Result<GraphState<S>, GraphError>

pub fn stream_invoke( &self, state: GraphState<S>, ) -> BoxStream<'_, Result<GraphEvent<S>, GraphError>>

pub fn stream_invoke_with_options( &self, state: GraphState<S>, options: ExecutionOptions, ) -> BoxStream<'_, Result<GraphEvent<S>, GraphError>>

pub async fn invoke_graph_with_options( &self, state: GraphState<S>, options: ExecutionOptions, ) -> Result<GraphState<S>, GraphError>

pub async fn invoke( &self, state: GraphState<S>, ) -> Result<GraphState<S>, WesichainError>

pub async fn invoke_with_options( &self, state: GraphState<S>, options: ExecutionOptions, ) -> Result<GraphState<S>, WesichainError>

pub async fn get_state( &self, thread_id: &str, ) -> Result<Option<GraphState<S>>, GraphError>

pub async fn resume( &self, checkpoint: Checkpoint<S>, options: ExecutionOptions, ) -> Result<GraphState<S>, GraphError>

pub async fn update_state( &self, thread_id: &str, values: S, as_node: Option<String>, ) -> Result<(), GraphError>

Trait Implementations

impl<S: StateSchema<Update = S>> Runnable<GraphState<S>, StateUpdate<S>> for ExecutableGraph<S>

fn invoke<'life0, 'async_trait>( &'life0 self, input: GraphState<S>, ) -> Pin<Box<dyn Future<Output = Result<StateUpdate<S>, WesichainError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stream<'a>( &'a self, input: GraphState<S>, ) -> BoxStream<'a, Result<StreamEvent, WesichainError>>

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn abatch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn to_serializable(&self) -> Option<SerializableRunnable>