Struct WorkflowRunner 

pub struct WorkflowRunner { /* private fields */ }

The main workflow runner that executes workflow definitions

Implementations

impl WorkflowRunner

pub fn new(workflow: WorkflowDefinition) -> WorkflowResult<Self>

Creates a new WorkflowRunner for the given workflow definition

pub fn with_secret_manager(self, manager: Arc<dyn SecretManager>) -> Self

Sets the secret manager for $secret expression variable

pub fn with_listener(self, listener: Arc<dyn WorkflowExecutionListener>) -> Self

Sets the execution listener for workflow/task events

pub fn with_event_bus(self, bus: SharedEventBus) -> Self

Sets the event bus for emit/listen tasks

pub fn with_sub_workflow(self, workflow: WorkflowDefinition) -> Self

Registers a sub-workflow that can be invoked via run: workflow Keyed by “namespace/name/version”

pub fn with_call_handler(self, handler: Box<dyn CallHandler>) -> Self

Registers a custom call handler for a specific call type (e.g., “grpc”, “openapi”, “asyncapi”, “a2a”)

pub fn with_run_handler(self, handler: Box<dyn RunHandler>) -> Self

Registers a custom run handler for a specific run type (e.g., “container”, “script”)

pub fn with_function(self, name: &str, task: TaskDefinition) -> Self

Registers a named function definition for call.function resolution

This allows registering external function definitions that can be referenced by call: <functionName> in workflows, similar to Java SDK’s cataloged function mechanism.

pub fn with_handler_registry(self, registry: HandlerRegistry) -> Self

Sets the entire handler registry (used for propagating handlers to child runners)

pub fn with_custom_task_handler( self, handler: Box<dyn CustomTaskHandler>, ) -> Self

Registers a custom task handler for a specific custom task type

pub async fn run(&self, input: Value) -> WorkflowResult<Value>

Runs the workflow with the given input and returns the output

pub fn workflow(&self) -> &WorkflowDefinition

Returns a reference to the workflow definition

pub fn handle(&self) -> WorkflowHandle

Returns a WorkflowHandle that can suspend/resume the running workflow

Must be called before run(). The handle shares suspend/resume state with the workflow context via Arc.

pub fn schedule(self, input: Value) -> ScheduledWorkflow

Runs the workflow on a recurring schedule based on the workflow’s schedule.every or schedule.cron definition.

For every: runs the workflow at fixed intervals. For cron: currently not supported (requires cron parsing library).

Returns a ScheduledWorkflow that can be cancelled to stop the schedule. If no schedule is defined, runs once and returns a completed handle.