Struct LongRunningWorkflow

pub struct LongRunningWorkflow<Context, Action, S>
where
    Context: Send + Sync + 'static,
    Action: ActionType + LongRunningActionExt + Send + Sync + 'static + Debug,
    S: StateStore,
{ /* private fields */ }

A workflow for orchestrating long-running nodes. This manages the suspension and resumption of nodes.

Implementations

impl<Context, Action, S> LongRunningWorkflow<Context, Action, S>

where Context: Send + Sync + 'static, Action: ActionType + LongRunningActionExt + Send + Sync + 'static + Debug, S: StateStore,

pub fn new(state_store: S) -> Self

Create a new long-running workflow

pub async fn execute_node<LRN>( &self, node: &LRN, ctx: &mut Context, ) -> Result<NodeOutcome<Action, Action>, FloxideError>

where LRN: LongRunningNode<Context, Action>,

Execute a single long-running node until completion or suspension

pub async fn has_suspended_state( &self, node_id: NodeId, ) -> Result<bool, FloxideError>

Check if a node has suspended state

pub async fn get_suspended_nodes(&self) -> Result<Vec<NodeId>, FloxideError>

Get all node IDs with suspended state