Struct WorkflowRuntime 

pub struct WorkflowRuntime { /* private fields */ }

Non-clone scheduler and display owner for one declared workflow plan.

Implementations

impl WorkflowRuntime

pub fn builder() -> WorkflowRuntimeBuilder

Starts an empty builder. At least one phase is mandatory.

pub fn phases(&self) -> &[Phase]

Borrows all registered phases in deterministic declaration order.

pub fn phase(&self, id: impl Into<PhaseId>) -> Option<&Phase>

Borrows one registered phase by stable ID.

pub fn cancellation_token(&self) -> CancellationToken

Returns a cheap token that can request or observe runtime cancellation.

pub fn unique_task_matching( &self, selector: &TaskSelector, ) -> Result<&Task, RuntimeError>

Returns the unique task matching an exact partial selector.

pub fn run_phases<I, P>(self, phases: I) -> Result<RuntimeSummary, RuntimeError>

where I: IntoIterator<Item = P>, P: Into<PhaseId>,

Runs exactly the selected phases; omitted unsatisfied dependencies fail.

pub fn run_phases_exact<I, P>( self, phases: I, ) -> Result<RuntimeSummary, RuntimeError>

where I: IntoIterator<Item = P>, P: Into<PhaseId>,

Runs exactly the selected phases; omitted unsatisfied dependencies fail.

pub fn run_phases_with_dependencies<I, P>( self, phases: I, ) -> Result<RuntimeSummary, RuntimeError>

where I: IntoIterator<Item = P>, P: Into<PhaseId>,

Adds unsatisfied dependencies and runs the deterministic closure.

Trait Implementations

impl Debug for WorkflowRuntime

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

Formats the value using the given formatter.