Struct Executor 

pub struct Executor {
    pub action_registry: Arc<RwLock<ActionRegistry>>,
    pub max_parallel: usize,
    pub max_retry_attempts: u32,
    pub retry_base_delay: Duration,
    pub retry_max_delay: Duration,
    pub strict_exports: bool,
    pub agent_step_executor: Option<Arc<dyn AgentStepExecutor>>,
    pub action_execution_options: ActionExecutionOptions,
}

The executor - orchestrates DAG execution

Fields

action_registry: Arc<RwLock<ActionRegistry>>

Action registry

max_parallel: usize

Maximum parallel executions

max_retry_attempts: u32

Max retries for ActionResult::RetryableError (excluding initial attempt).

retry_base_delay: Duration

Base delay for exponential backoff when action does not provide retry_after.

retry_max_delay: Duration

Cap for exponential backoff delay.

strict_exports: bool

Whether declared exports are required at runtime.

agent_step_executor: Option<Arc<dyn AgentStepExecutor>>

Optional runtime hook for handling agent steps.

action_execution_options: ActionExecutionOptions

Optional execution options applied to all non-agent action executions.

Implementations

impl Executor

pub fn new(action_registry: ActionRegistry) -> Executor

Create a new executor

pub fn with_registry(action_registry: Arc<RwLock<ActionRegistry>>) -> Executor

Create a new executor with a shared registry

pub fn with_max_parallel(self, max: usize) -> Executor

Set maximum parallel executions

pub fn with_retry_policy( self, max_retry_attempts: u32, retry_base_delay: Duration, retry_max_delay: Duration, ) -> Executor

Configure retry policy for retryable action errors.

pub fn with_export_contract(self, strict_exports: bool) -> Executor

Configure strict runtime checks for step exports.

pub fn with_agent_step_executor( self, agent_executor: Arc<dyn AgentStepExecutor>, ) -> Executor

Configure runtime-provided executor for StepKind::Agent.

pub fn with_action_execution_options( self, options: ActionExecutionOptions, ) -> Executor

Configure common action execution options.

pub fn with_action_preflight_hook( self, hook: Arc<dyn Fn(&str, &Value) -> Option<String> + Send + Sync>, ) -> Executor

Configure a preflight hook for non-agent action execution.

pub async fn execute( &self, dag: &mut ExecutionDag, ctx: &ExecutorContext, ) -> ExecutionResult

Execute a DAG