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>, engine: Arc<Engine>) -> Self

Create a new WorkflowExecutor

pub fn task_functions(&self) -> Arc<HashMap<String, BoxedFunctionHandler>>

Get a clone of the task_functions Arc for reuse in new engines

pub async fn execute( &self, workflow: &Workflow, message: &mut Message, now: DateTime<Utc>, ) -> 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

pub async fn execute_with_trace( &self, workflow: &Workflow, message: &mut Message, trace: &mut ExecutionTrace, now: DateTime<Utc>, ) -> Result<bool>

Execute a workflow with step-by-step tracing

Similar to execute but records execution steps for debugging.

pub async fn run_all( &self, workflows: &[&Workflow], message: &mut Message, trace: Option<&mut ExecutionTrace>, now: DateTime<Utc>, ) -> Result<()>

Drive a message through workflows in order, grouping maximal runs of consecutive fully_sync workflows into a single shared-arena scope (execute_sync_workflow_run) and falling back to the per-workflow .await path (execute_inner) for any workflow containing an async task. This is the single orchestration entry for all four Engine::process_message* variants.