Struct WorkflowInstance 

pub struct WorkflowInstance { /* private fields */ }

Workflow instance (runtime state)

Corresponds to Lean: structure WorkflowInstance

Uses dense arrays indexed by node position for O(1) state access. Maintains counters for O(1) aggregate queries.

Implementations

impl WorkflowInstance

pub fn new( workflow_def: WorkflowDef, timeout_at: Time, max_retries: u64, ) -> Self

Create a new workflow instance

pub fn running(timeout_at: Time) -> Self

Create a simple running workflow instance with specified timeout

Useful for tests where we just need a running workflow.

pub fn is_running(&self) -> bool

Check if this workflow is running

Convenience method that delegates to status().is_running()

pub fn get_node_state(&self, n: u64) -> NodeState

Get node state by node ID.

Returns Pending for nodes that exist in the definition but have no explicit state entry yet. For nodes NOT in the definition, also returns Pending (callers should use require_node() first for validation).

pub fn is_pending(&self, n: u64) -> bool

Check if node is in pending state

Corresponds to Lean: def WorkflowInstance.is_pending

pub fn is_active(&self, n: u64) -> bool

Check if node is in active state

Corresponds to Lean: def WorkflowInstance.is_active

pub fn pending_count(&self) -> usize

Count pending nodes (O(1))

Corresponds to Lean: def WorkflowInstance.pending_count

pub fn active_count(&self) -> usize

Count active nodes (O(1))

Corresponds to Lean: def WorkflowInstance.active_count

pub fn is_terminal(&self) -> bool

Check if all nodes are terminal (completed or failed) (O(1))

Corresponds to Lean: def WorkflowInstance.is_terminal

pub fn has_failure(&self) -> bool

Check if at least one node failed (O(1))

Corresponds to Lean: def WorkflowInstance.has_failure

pub fn status(&self) -> WorkflowStatus

Get the workflow status

pub fn timeout_at(&self) -> Time

Get the timeout deadline

pub fn get_retries(&self, n: u64) -> u64

Get retry count for a node

pub fn definition(&self) -> &WorkflowDef

Get a reference to the definition

pub fn dependencies_satisfied(&self, n: u64) -> bool

Check if dependencies are satisfied for a node

pub fn start_node(&mut self, n: u64) -> Result<(), WorkflowError>

Start a pending node (transition to active)

Returns Err if node not in definition, not pending, or dependencies not satisfied.

Errors

Returns WorkflowError::NodeNotFound if the node is not in the workflow definition. Returns WorkflowError::InvalidTransition if the node is not in the Pending state. Returns WorkflowError::DependenciesNotSatisfied if upstream nodes are not yet completed.

pub fn complete_node(&mut self, n: u64) -> Result<(), WorkflowError>

Complete an active node (transition to completed)

Errors

Returns WorkflowError::NodeNotFound if the node is not in the workflow definition. Returns WorkflowError::InvalidTransition if the node is not in the Active state.

pub fn fail_node(&mut self, n: u64) -> Result<(), WorkflowError>

Fail an active node (transition to failed)

Errors

Returns WorkflowError::NodeNotFound if the node is not in the workflow definition. Returns WorkflowError::InvalidTransition if the node is not in the Active state.

pub fn apply_timeout(&mut self)

Apply timeout

pub fn measure(&self, now: Time) -> u64

Calculate the termination measure

Corresponds to Lean: def workflow_measure

A natural number that decreases on each workflow step.

Trait Implementations

impl Clone for WorkflowInstance

fn clone(&self) -> WorkflowInstance

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkflowInstance

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WorkflowInstance

fn default() -> WorkflowInstance

Returns the “default value” for a type.