Skip to main content

Module task_executor

Module task_executor 

Source
Expand description

§Task Execution Module

Dispatches a single Task to its function implementation. Built-in sync variants of FunctionConfig are dispatched in workflow_executor’s sync stretch via FunctionConfig::try_execute_in_arena; this module owns the async path — HttpCall, Enrich, PublishKafka, and Custom — routed to the matching registered handler.

Structs§

TaskExecutor
Handles the execution of tasks with their associated functions.