Struct WorkflowExecutor 

pub struct WorkflowExecutor { /* private fields */ }

Executes workflows.

Implementations

impl WorkflowExecutor

pub fn new( registry: Arc<WorkflowRegistry>, pool: PgPool, http_client: CircuitBreakerClient, ) -> Self

Create a new workflow executor.

pub async fn start<I: Serialize>( &self, workflow_name: &str, input: I, owner_subject: Option<String>, ) -> Result<Uuid>

Start a new workflow on the active version. Returns immediately with the run_id; workflow executes in the background.

pub async fn resume(&self, run_id: Uuid) -> Result<WorkflowResult>

Resume a workflow from where it left off.

pub async fn resume_from_sleep(&self, run_id: Uuid) -> Result<WorkflowResult>

Resume a workflow after a sleep timer expired.

pub async fn status(&self, run_id: Uuid) -> Result<WorkflowRecord>

Get workflow status.

pub async fn cancel(&self, run_id: Uuid) -> Result<()>

Cancel a workflow and run compensation.

Compensation follows the saga pattern: steps are undone in reverse order of their completion. This ensures that dependencies are respected. For example, if step A created a resource that step B modified, we must undo B’s modification before deleting A’s resource.

Compensation handlers receive the original step result, allowing them to know exactly what to undo (e.g., refund the specific payment ID).

pub async fn cancel_by_operator(&self, run_id: Uuid, reason: &str) -> Result<()>

Cancel a workflow run by operator decision. Terminal action that preserves audit trail.

pub async fn retire_unresumable(&self, run_id: Uuid, reason: &str) -> Result<()>

Retire a workflow run as unresumable. Terminal action for blocked runs.

pub async fn save_step(&self, step: &WorkflowStepRecord) -> Result<()>

Save step record.

pub async fn start_by_name( &self, workflow_name: &str, input: Value, owner_subject: Option<String>, ) -> Result<Uuid>

Start a workflow by its registered name with JSON input.

Trait Implementations

impl WorkflowDispatch for WorkflowExecutor

fn get_info(&self, workflow_name: &str) -> Option<WorkflowInfo>

Get workflow info by name for auth checking.

fn start_by_name( &self, workflow_name: &str, input: Value, owner_subject: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + '_>>

Start a workflow by its registered name.