Enum ApplyError 

pub enum ApplyError {
    Postgres(Error),
    PlanIo(PlanIoError),
    Catalog(CatalogError),
    LockHeld,
    TargetIdentityMismatch {
        plan: String,
        live: String,
    },
    DriftDetected(usize),
    UnapprovedIntents {
        count: usize,
        details: Vec<(u32, String, String)>,
    },
    StepFailed {
        step_no: u32,
        group_no: u32,
        error: String,
    },
    AbortedAfterStep {
        step_no: u32,
    },
    LintWaiverMissing {
        count: usize,
        details: Vec<(String, String)>,
    },
    MissingEnvVar(String, u32),
    Internal(String),
}

Errors raised by apply and its sub-stages.

Variants

Postgres(Error)

tokio_postgres reported an error.

PlanIo(PlanIoError)

Reading the plan directory failed.

Catalog(CatalogError)

Catalog read or assemble failed during preflight.

LockHeld

The advisory lock is already held by another session.

TargetIdentityMismatch

The live target’s identity hash does not match the plan’s.

Fields

plan: String

Plan-time target identity.

live: String

Live identity computed at apply time.

DriftDetected(usize)

The live catalog has drifted from the plan’s target_snapshot since planning. The list of changes is rendered for the user.

UnapprovedIntents

One or more destructive intents were not approved.

Fields

count: usize

Number of unapproved intents.

details: Vec<(u32, String, String)>

Brief listing for diagnostics: (id, target, reason) per intent.

StepFailed

A single step failed; the executor rolled back the enclosing group (if transactional) or stopped (if not).

Fields

step_no: u32

Failing step number.

group_no: u32

Enclosing group id.

error: String

Postgres error message.

AbortedAfterStep

The executor aborted cleanly after a step because the caller passed ApplyOverrides::abort_after_step. Used by the testkit’s chaos harness to validate the re-plan-and-resume recovery path.

Fields

step_no: u32

Step at which the abort fired.

LintWaiverMissing

One or more LintAtPlan findings lack a matching [[lint_waiver]] in intent.toml. The plan cannot be applied until waivers are added or the source is corrected.

Fields

count: usize

Number of unwaived findings.

details: Vec<(String, String)>

Brief listing for diagnostics: (rule, target) per finding.

MissingEnvVar(String, u32)

A plan step’s SQL referenced an env var that wasn’t set.

Internal(String)

An internal invariant was violated or an unexpected value was encountered.

Used for failures that are not Postgres errors (e.g., parsing a value returned from Postgres that should always be valid, but is not).

Trait Implementations

impl Debug for ApplyError

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

Formats the value using the given formatter.

impl Display for ApplyError

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

Formats the value using the given formatter.

impl Error for ApplyError

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<CatalogError> for ApplyError

fn from(source: CatalogError) -> Self

Converts to this type from the input type.

impl From<Error> for ApplyError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<PlanIoError> for ApplyError

fn from(source: PlanIoError) -> Self

Converts to this type from the input type.