Struct TaskExecutor 

pub struct TaskExecutor { /* private fields */ }

Handles the execution of tasks with their associated functions

The TaskExecutor is responsible for:

• Executing built-in functions (map, validation)
• Executing custom async function handlers
• Managing function registry
• Handling task-level error recovery

Implementations

impl TaskExecutor

pub fn new( task_functions: Arc<HashMap<String, Box<dyn AsyncFunctionHandler + Send + Sync>>>, executor: Arc<InternalExecutor>, datalogic: Arc<DataLogic>, ) -> Self

Create a new TaskExecutor

pub async fn execute( &self, task: &Task, message: &mut Message, ) -> Result<(usize, Vec<Change>)>

Execute a single task

This method:

1. Determines the function type (built-in or custom)
2. Executes the appropriate handler
3. Returns the status code and changes for audit trail

Arguments

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

Returns

• Result<(usize, Vec<Change>)> - Status code and changes, or error

pub fn has_function(&self, name: &str) -> bool

Check if a function handler exists

pub fn custom_function_count(&self) -> usize

Get the count of registered custom functions