Enum RepositoryError 

#[non_exhaustive]
pub enum RepositoryError {
    SchemaUninitialized,
    MigrationRequired {
        current: u32,
        supported: u32,
    },
    NewerSchema {
        current: u32,
        supported: u32,
    },
    IdentifierOutOfRange {
        kind: IdentifierKind,
        value: u64,
    },
    JobInstanceNotFound {
        id: JobInstanceId,
    },
    JobExecutionNotFound {
        id: JobExecutionId,
    },
    StepExecutionNotFound {
        id: StepExecutionId,
    },
    StepPartitionNotFound {
        id: StepPartitionId,
    },
    EmptyPartitionPlan,
    PartitionPlanTooLarge {
        max: usize,
    },
    DuplicatePartitionKey,
    PartitionPlanExists {
        step_execution_id: StepExecutionId,
    },
    PartitionPlanNotCommitted {
        step_execution_id: StepExecutionId,
    },
    PartitionUpdateNotAllowed {
        id: StepPartitionId,
        status: BatchStatus,
    },
    PartitionWorkerMismatch {
        partition_id: StepPartitionId,
        worker_step_execution_id: StepExecutionId,
    },
    PartitionWorkerAlreadyAssigned {
        worker_step_execution_id: StepExecutionId,
    },
    PartitionWorkerStale {
        partition_id: StepPartitionId,
        worker_step_execution_id: StepExecutionId,
    },
    PartitionParentNotActive {
        step_execution_id: StepExecutionId,
        status: BatchStatus,
    },
    PartitionAggregationIncomplete {
        step_execution_id: StepExecutionId,
        status: BatchStatus,
    },
    PartitionStateCorrupt,
    DuplicateIdentifier {
        kind: IdentifierKind,
        value: u64,
    },
    CompletedInstance {
        id: JobInstanceId,
    },
    AbandonedInstance {
        id: JobInstanceId,
    },
    ExecutionAlreadyActive {
        instance_id: JobInstanceId,
        execution_id: JobExecutionId,
        status: BatchStatus,
    },
    DefinitionDrift {
        job_name: JobName,
        revision: DefinitionRevision,
    },
    DefinitionJobMismatch {
        expected: JobName,
        actual: JobName,
    },
    IncompatibleDefinition {
        instance_id: JobInstanceId,
    },
    UnsupportedManifestVersion {
        format: u16,
    },
    InvalidDefinitionUpgrade {
        execution_id: JobExecutionId,
    },
    DefinitionUpgradeConflict {
        job_name: JobName,
    },
    RestartStateNotFound {
        execution_id: JobExecutionId,
        step_name: StepName,
    },
    FaultStateCorrupt,
    StartLimitExceeded {
        instance_id: JobInstanceId,
        node_id: NodeId,
        limit: StartLimit,
    },
    FlowStateCorrupt,
    RecoveryNotAllowed {
        id: JobExecutionId,
        status: BatchStatus,
    },
    ExecutionOwned {
        id: JobExecutionId,
    },
    ExecutionOwnershipNotAllowed {
        id: JobExecutionId,
        status: BatchStatus,
    },
    Domain(DomainError),
    Identifier(IdGenerationError),
    Lifecycle(LifecycleError),
    RetentionPlanStale,
    UnsupportedCapability {
        capability: RepositoryCapability,
    },
    ConcurrentModification,
    CommitOutcomeUnknown,
    Unavailable,
}

A stable repository failure independent of a database or async runtime.

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.

SchemaUninitialized

The durable metadata schema has not been initialized.

MigrationRequired

The durable metadata schema must be migrated before use.

Fields

current: u32

The version found in the database.

supported: u32

The version understood by this runtime.

NewerSchema

The durable metadata schema is newer than this runtime.

Fields

current: u32

The version found in the database.

supported: u32

The version understood by this runtime.

IdentifierOutOfRange

A facade identifier cannot be represented by the durable adapter.

Fields

kind: IdentifierKind

The identifier category.

value: u64

The rejected facade value.

JobInstanceNotFound

A referenced job instance does not exist.

Fields

id: JobInstanceId

The missing identifier.

JobExecutionNotFound

A referenced job execution does not exist.

Fields

id: JobExecutionId

The missing identifier.

StepExecutionNotFound

A referenced step execution does not exist.

Fields

id: StepExecutionId

The missing identifier.

StepPartitionNotFound

A referenced durable step partition does not exist.

Fields

id: StepPartitionId

The missing partition identifier.

EmptyPartitionPlan

A partition plan contained no work.

PartitionPlanTooLarge

A partition plan exceeded the accepted M4 bound.

Fields

max: usize

Maximum accepted partition count.

DuplicatePartitionKey

A partition plan repeated a byte-exact key.

PartitionPlanExists

A durable plan already exists for the parent step execution.

Fields

step_execution_id: StepExecutionId

Parent partitioned step execution.

PartitionPlanNotCommitted

Worker assignment was attempted before the new plan transaction committed.

Fields

step_execution_id: StepExecutionId

Parent partitioned step execution.

PartitionUpdateNotAllowed

A partition update was not valid for its durable state.

Fields

id: StepPartitionId

Rejected partition.

status: BatchStatus

Status observed under compare-and-swap.

PartitionWorkerMismatch

The worker attempt does not belong to the partition parent’s job execution.

Fields

partition_id: StepPartitionId

Rejected partition.

worker_step_execution_id: StepExecutionId

Worker attempt from a different job execution.

PartitionWorkerAlreadyAssigned

A worker attempt is already bound to another durable partition.

Fields

worker_step_execution_id: StepExecutionId

Reused worker attempt.

PartitionWorkerStale

A completion did not name the currently assigned worker attempt.

Fields

partition_id: StepPartitionId

Rejected partition.

worker_step_execution_id: StepExecutionId

Worker expected by the caller.

PartitionParentNotActive

The partition manager is no longer active and cannot mutate children.

Fields

step_execution_id: StepExecutionId

Parent partitioned step execution.

status: BatchStatus

Current parent lifecycle status.

PartitionAggregationIncomplete

At least one durable child has not published a runtime-terminal result.

Fields

step_execution_id: StepExecutionId

Parent partitioned step execution.

status: BatchStatus

Child status that prevented aggregation.

PartitionStateCorrupt

Durable partition state is contradictory, corrupt, or cannot be decoded.

DuplicateIdentifier

An injected source reused an existing identifier.

Fields

kind: IdentifierKind

The duplicated identifier category.

value: u64

The duplicated numeric value.

CompletedInstance

A completed logical instance cannot be launched again.

Fields

id: JobInstanceId

The terminal logical instance.

AbandonedInstance

An abandoned logical instance cannot be launched again.

Fields

id: JobInstanceId

The terminal logical instance.

ExecutionAlreadyActive

A prior attempt is active or requires explicit recovery.

Fields

instance_id: JobInstanceId

The logical instance selected for launch.

execution_id: JobExecutionId

The attempt preventing another launch.

status: BatchStatus

Its current framework status.

DefinitionDrift

One job name and revision were bound to a different manifest.

Fields

job_name: JobName

Definition whose application revision drifted.

revision: DefinitionRevision

Reused application-owned revision.

DefinitionJobMismatch

A manifest was registered or launched under a different job name.

Fields

expected: JobName

Job name selected by the instance or registration call.

actual: JobName

Job name encoded in the definition manifest.

IncompatibleDefinition

The proposed definition cannot interpret the latest checkpoint.

Fields

instance_id: JobInstanceId

Logical instance whose last definition is incompatible.

UnsupportedManifestVersion

The runtime cannot interpret the supplied or persisted manifest format.

Fields

format: u16

Unsupported format version.

InvalidDefinitionUpgrade

A registered directed edge did not map a required durable step.

Fields

execution_id: JobExecutionId

New execution whose mapped state could not be resolved.

DefinitionUpgradeConflict

A directed edge was already registered with different immutable content.

Fields

job_name: JobName

Job whose edge conflicted.

RestartStateNotFound

A restartable definition required durable step state that was absent.

Fields

execution_id: JobExecutionId

New restart execution.

step_name: StepName

Target step whose source state was absent.

FaultStateCorrupt

Durable fault state could not be interpreted, so no work may begin.

Corruption, an unsupported fault-state version, a checksum mismatch, or state that belongs to a superseded checkpoint fails closed.

StartLimitExceeded

The instance-wide start limit for a logical step is exhausted.

Fields

instance_id: JobInstanceId

Logical instance whose historical starts were counted.

node_id: NodeId

Stable logical step identifier.

limit: StartLimit

Configured finite limit.

FlowStateCorrupt

Durable flow history is missing, contradictory, or corrupt.

RecoveryNotAllowed

Recovery was requested for a state that needs no recovery decision.

Fields

id: JobExecutionId

Rejected execution.

status: BatchStatus

Durable status observed under lock.

ExecutionOwned

A different process token is already recorded for the execution.

Fields

id: JobExecutionId

Execution that remains owned by another process token.

ExecutionOwnershipNotAllowed

Ownership was requested outside the newly-created STARTING boundary.

Fields

id: JobExecutionId

Execution that was not claimable.

status: BatchStatus

Durable status observed under lock.

Domain(DomainError)

A domain value could not be constructed.

Identifier(IdGenerationError)

An injected identifier source failed.

Lifecycle(LifecycleError)

A lifecycle or optimistic-version rule rejected an update.

RetentionPlanStale

A purge candidate changed after its plan was produced.

Nothing was deleted. A new plan observes the remaining candidates.

UnsupportedCapability

The adapter does not provide a required repository capability.

Fields

capability: RepositoryCapability

The capability the caller required.

ConcurrentModification

Another committed unit of work invalidated this snapshot.

CommitOutcomeUnknown

A commit failed after PostgreSQL may have made it durable.

Callers must inspect durable metadata through a new healthy unit of work before deciding whether to retry.

Unavailable

The repository is unavailable because of an infrastructure failure.

Trait Implementations

impl Clone for RepositoryError

fn clone(&self) -> RepositoryError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RepositoryError

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

Formats the value using the given formatter.

impl Display for RepositoryError

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

Formats the value using the given formatter.

impl Eq for RepositoryError

impl Error for RepositoryError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl From<DomainError> for RepositoryError

fn from(error: DomainError) -> RepositoryError

Converts to this type from the input type.

impl From<IdGenerationError> for RepositoryError

fn from(error: IdGenerationError) -> RepositoryError

Converts to this type from the input type.

impl From<LifecycleError> for RepositoryError

fn from(error: LifecycleError) -> RepositoryError

Converts to this type from the input type.

impl From<RepositoryError> for ExplorerError

fn from(value: RepositoryError) -> ExplorerError

Converts to this type from the input type.

impl From<RepositoryError> for RetentionError

fn from(value: RepositoryError) -> RetentionError

Converts to this type from the input type.

impl From<RepositoryError> for FlowRuntimeError

fn from(error: RepositoryError) -> Self

Converts to this type from the input type.

impl From<RepositoryError> for LaunchError

fn from(error: RepositoryError) -> Self

Converts to this type from the input type.

impl From<RepositoryError> for OperatorError

fn from(value: RepositoryError) -> Self

Converts to this type from the input type.

impl PartialEq for RepositoryError

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RepositoryError