Enum InvocationStatus 

#[non_exhaustive]
pub enum InvocationStatus {
    Registered,
    ConcurrencyControlled,
    ConcurrencyControlledFinal,
    Rerouted,
    Pending,
    PendingRecovery,
    Running,
    RunningRecovery,
    Paused,
    Resumed,
    Killed,
    Success,
    Failed,
    Retry,
}

The lifecycle status of an invocation.

Follows a strict state machine — not all transitions are valid. Mirrors pynenc’s InvocationStatus enum exactly.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Registered

Invocation created and registered

ConcurrencyControlled

Paused due to concurrency control (transient — will be rerouted)

ConcurrencyControlledFinal

Permanently blocked by concurrency control

Rerouted

Re-queued in the broker for another execution attempt

Pending

Queued in the broker, waiting for a runner

PendingRecovery

Pending recovery after runner failure (timeout exceeded)

Running

Currently being executed by a runner

RunningRecovery

Being re-executed during recovery (owner runner inactive)

Paused

Task execution is paused

Resumed

Task execution has been resumed after pause

Killed

Task execution has been killed

Success

Completed successfully

Failed

Failed with an error

Retry

Marked for retry after a failure

Implementations

impl InvocationStatus

pub fn is_terminal(&self) -> bool

Returns true if this is a terminal (final) status.

pub fn is_available_for_run(&self) -> bool

Returns true if this status means the invocation can be picked up by a runner.

pub fn valid_transitions(&self) -> &[InvocationStatus]

Returns the set of valid next states from this status.

pub fn can_transition_to(&self, next: InvocationStatus) -> bool

Check if transitioning to next is valid.

pub fn final_statuses() -> &'static [InvocationStatus]

Returns all terminal statuses.

pub fn available_for_run_statuses() -> &'static [InvocationStatus]

Returns all statuses where invocations can be picked up by runners.

Trait Implementations

impl Clone for InvocationStatus

fn clone(&self) -> InvocationStatus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InvocationStatus

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for InvocationStatus

fn deserialize<__D>( __deserializer: __D, ) -> Result<InvocationStatus, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for InvocationStatus

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

Formats the value using the given formatter.

impl FromStr for InvocationStatus

type Err = String

The associated error which can be returned from parsing.

fn from_str( s: &str, ) -> Result<InvocationStatus, <InvocationStatus as FromStr>::Err>

Parses a string s to return a value of this type.

impl Hash for InvocationStatus

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for InvocationStatus

fn eq(&self, other: &InvocationStatus) -> 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 Serialize for InvocationStatus

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for InvocationStatus

impl Eq for InvocationStatus

impl StructuralPartialEq for InvocationStatus