Struct TaskExecutor 

pub struct TaskExecutor { /* private fields */ }

Handles the execution of tasks with their associated functions.

The TaskExecutor is responsible for:

• Routing async functions (http_call, enrich, publish_kafka, custom) to the matching registered handler via [crate::engine::functions::DynAsyncFunctionHandler]
• Owning the function registry

Sync built-ins are not routed through execute — workflow_executor calls FunctionConfig::try_execute_in_arena inside its sync stretch for those, sharing one arena across consecutive sync tasks.

Implementations

impl TaskExecutor

pub fn new( task_functions: Arc<HashMap<String, BoxedFunctionHandler>>, engine: Arc<Engine>, ) -> Self

Create a new TaskExecutor

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

Execute a single task. Sync built-ins reach here only when called from outside the workflow executor’s sync-stretch path — they fall back to their execute() methods (which open a fresh thread-local arena).

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

Check if a function handler exists

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

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

pub fn custom_function_count(&self) -> usize

Get the count of registered custom functions