Struct WorkflowExecutor 

pub struct WorkflowExecutor { /* private fields */ }

Handles the execution of workflows and their tasks

The WorkflowExecutor is responsible for:

• Evaluating workflow conditions
• Orchestrating task execution within workflows
• Managing workflow-level error handling
• Recording audit trails

Implementations

impl WorkflowExecutor

pub fn new( task_executor: Arc<TaskExecutor>, internal_executor: Arc<InternalExecutor>, ) -> Self

Create a new WorkflowExecutor

pub async fn execute( &self, workflow: &Workflow, message: &mut Message, ) -> Result<bool>

Execute a workflow if its condition is met

This method:

1. Evaluates the workflow condition
2. Executes tasks sequentially if condition is met
3. Handles error recovery based on workflow configuration
4. Updates message metadata and audit trail

Arguments

• workflow - The workflow to execute
• message - The message being processed

Returns

• Result<bool> - Ok(true) if workflow was executed, Ok(false) if skipped, Err on failure