Struct WorkflowRunSummary 

pub struct WorkflowRunSummary { /* private fields */ }

Aggregate outcome for one workflow run.

Implementations

impl WorkflowRunSummary

pub const fn new(scheduled_node_count: usize) -> Self

Start an empty summary for a run with scheduled_node_count nodes.

pub const fn terminal_state(&self) -> WorkflowTerminalState

Terminal state after all scheduled node runs were observed.

pub const fn scheduled_node_count(&self) -> usize

Number of nodes scheduled for execution.

pub const fn completed_node_count(&self) -> usize

Number of nodes that completed successfully.

pub const fn failed_node_count(&self) -> usize

Number of nodes that returned a non-cancellation error.

pub const fn cancelled_node_count(&self) -> usize

Number of nodes that returned a cancellation error.

pub const fn observed_message_count(&self) -> usize

Number of message observations accounted for by the workflow runner.

This remains zero until queue-pressure/message accounting is attached to the runner in the observability tranche.

pub const fn error_count(&self) -> usize

Number of node results that ended in an error.

pub const fn pending_node_count(&self) -> usize

Number of scheduled nodes that have not yet reached a terminal state.

pub const fn first_error(&self) -> Option<&PureflowError>

First error observed by the workflow runner, if any.

pub const fn deadlock_diagnostic(&self) -> Option<&WorkflowDeadlockDiagnostic>

Deadlock diagnostic captured by the workflow watchdog, if it fired.

pub fn into_result(self) -> Result<()>

Convert a summary into the legacy Result<()> shape.

Errors

Returns the first observed workflow error when the terminal state is not WorkflowTerminalState::Completed.

Trait Implementations

impl Clone for WorkflowRunSummary

fn clone(&self) -> WorkflowRunSummary

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowRunSummary

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

Formats the value using the given formatter.

impl PartialEq for WorkflowRunSummary

fn eq(&self, other: &WorkflowRunSummary) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for WorkflowRunSummary

impl StructuralPartialEq for WorkflowRunSummary