Struct WorkflowExecutor 

pub struct WorkflowExecutor<E: TaskExecutor> { /* private fields */ }

Workflow executor.

Implementations

impl<E: TaskExecutor> WorkflowExecutor<E>

pub fn new(config: ExecutorConfig, task_executor: E) -> Self

Create a new workflow executor.

pub async fn execute( &self, workflow_id: String, execution_id: String, dag: WorkflowDag, ) -> Result<WorkflowState>

Execute a workflow.

pub async fn resume(&self, execution_id: String) -> Result<WorkflowState>

Resume a workflow from a saved checkpoint.

This method reconstructs the DAG from the checkpoint and continues execution from where it left off, handling:

• Completed tasks (skipped)
• Interrupted tasks (reset to pending for retry)
• Failed tasks (depending on configuration)
• Pending tasks (executed normally)

pub async fn resume_from_sequence( &self, execution_id: String, sequence: u64, ) -> Result<WorkflowState>

Resume a workflow from a specific checkpoint sequence.

pub async fn get_recovery_info( &self, execution_id: &str, ) -> Result<RecoveryInfo>

Get recovery information for an execution.

pub async fn list_checkpoints(&self, execution_id: &str) -> Result<Vec<u64>>

List available checkpoints for an execution.

pub async fn cleanup_checkpoints( &self, execution_id: &str, keep_count: usize, ) -> Result<usize>

Clean up old checkpoints, keeping only the latest N.