Struct WorkflowExecutor 

pub struct WorkflowExecutor { /* private fields */ }

An Executor that runs a child Workflow, enabling hierarchical composition.

Implementations

impl WorkflowExecutor

pub fn new(id: impl Into<String>, workflow: Workflow) -> WorkflowExecutor

Wrap workflow as an executor with the given id.

By default the child’s outputs are sent onward as messages from this node. Use WorkflowExecutor::with_direct_output to instead yield them directly as parent workflow outputs.

pub fn with_direct_output(self, allow: bool) -> WorkflowExecutor

Yield the child’s outputs directly to the parent’s output stream instead of forwarding them as messages.

pub fn workflow(&self) -> &Workflow

The wrapped child workflow.

Trait Implementations

impl Executor for WorkflowExecutor

fn id(&self) -> &str

A unique id for this executor within the workflow.

fn execute<'life0, 'async_trait>( &'life0 self, message: Value, ctx: WorkflowContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, WorkflowExecutor: 'async_trait,

Handle an incoming message.

fn snapshot_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Value>> + Send + 'async_trait>>

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

Capture serializable state for checkpointing.

fn restore_state<'life0, 'async_trait>( &'life0 self, _state: Value, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Restore state previously produced by Executor::snapshot_state.