Enum SubWorkflowOutcome 

pub enum SubWorkflowOutcome {
    Completed(SubWorkflowOutput),
    Conflict(ConcurrencyConflict),
}

Result of a workflow_with step.

Examples

use ironflow_engine::executor::{ConcurrencyConflict, SubWorkflowOutcome};
use uuid::Uuid;

let outcome = SubWorkflowOutcome::Conflict(ConcurrencyConflict::new("issue:12", Uuid::nil()));
match &outcome {
    SubWorkflowOutcome::Completed(output) => println!("child run {}", output.run_id()),
    SubWorkflowOutcome::Conflict(conflict) => println!("held by {}", conflict.run_id()),
}
assert!(outcome.output().is_none());

Variants

Completed(SubWorkflowOutput)

The child run was created and finished.

Conflict(ConcurrencyConflict)

No child run was created: another active run holds the concurrency key.

Implementations

impl SubWorkflowOutcome

pub fn conflict(&self) -> Option<&ConcurrencyConflict>

The conflict, when no child run was created.

Examples

use ironflow_engine::executor::{ConcurrencyConflict, SubWorkflowOutcome};
use uuid::Uuid;

let outcome = SubWorkflowOutcome::Conflict(ConcurrencyConflict::new("k", Uuid::nil()));
assert_eq!(outcome.conflict().map(|c| c.key()), Some("k"));

pub fn output(&self) -> Option<&SubWorkflowOutput>

The child result, when the child run was created and finished.

Examples

use ironflow_engine::executor::{SubWorkflowOutcome, SubWorkflowOutput};
use ironflow_store::entities::RunStatus;
use rust_decimal::Decimal;
use uuid::Uuid;

let output = SubWorkflowOutput::new(Uuid::nil(), "collect", RunStatus::Completed, Decimal::ZERO, 0);
let outcome = SubWorkflowOutcome::Completed(output.clone());
assert_eq!(outcome.output(), Some(&output));
assert!(outcome.conflict().is_none());

Trait Implementations

impl Clone for SubWorkflowOutcome

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubWorkflowOutcome

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

Formats the value using the given formatter.

impl PartialEq for SubWorkflowOutcome

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SubWorkflowOutcome