Enum DeltaFunnelError 

pub enum DeltaFunnelError {
    Config {
        message: String,
    },
    InvalidSourceName {
        name: String,
        reason: &'static str,
    },
    DuplicateSourceName {
        name: String,
    },
    InvalidSourceUri {
        reason: &'static str,
    },
    DeltaSourceEngine {
        reason: &'static str,
    },
    DeltaSnapshotLoad {
        reason: String,
    },
    DeltaProtocolCompatibility {
        source_name: String,
        table_uri: String,
        snapshot_version: u64,
        reason: String,
    },
    DeltaSourceSchema {
        source_name: String,
        table_uri: String,
        reason: String,
    },
    DataFusionRegistration {
        source_name: String,
        table_uri: String,
        reason: String,
    },
    SqlTable {
        phase: SqlTablePhase,
        message: String,
    },
    DeltaScanProjection {
        source_name: String,
        table_uri: String,
        reason: String,
    },
    DeltaScanFilter {
        source_name: String,
        table_uri: String,
        reason: String,
    },
    DeltaScanConstruction {
        source_name: String,
        table_uri: String,
        source: Box<Error>,
    },
    DeltaScanMetadataExpansion {
        source_name: String,
        table_uri: String,
        snapshot_version: u64,
        source: Box<Error>,
    },
    DeltaScanFileTaskPlanning {
        source_name: String,
        table_uri: String,
        snapshot_version: u64,
        path: String,
        reason: String,
    },
    DeltaScanFileTaskPartitionPlanning {
        source_name: String,
        table_uri: String,
        snapshot_version: u64,
        reason: String,
    },
    DeltaScanFileRead {
        source_name: String,
        table_uri: String,
        snapshot_version: u64,
        path: String,
        phase: DeltaScanFileReadPhase,
        source: Box<Error>,
    },
    DeltaScanDeletionVector {
        source_name: String,
        table_uri: String,
        snapshot_version: u64,
        path: String,
        phase: DeltaScanDeletionVectorPhase,
        source: Box<Error>,
    },
    DependencyCompatibility {
        message: String,
    },
    BatchPipeline {
        phase: BatchPipelinePhase,
        option: &'static str,
        message: String,
    },
    MssqlTargetConfig {
        option: &'static str,
        message: String,
    },
    MissingMssqlConnection {
        output_name: String,
    },
    InvalidMssqlOutputIdentity {
        output_name: String,
        reason: &'static str,
    },
    DuplicateMssqlOutputField {
        output_name: String,
        field_name: String,
        first_index: usize,
        duplicate_index: usize,
    },
    MssqlSchemaPlanning {
        output_name: String,
        diagnostics: DiagnosticSet,
    },
    MssqlSchemaPlanningFailed {
        output_name: String,
        source: Error,
    },
    MssqlDdlTargetIdentifier {
        output_name: String,
        source: Error,
    },
    MssqlDdlPlanning {
        output_name: String,
        message: String,
    },
    MssqlLifecyclePlanning {
        output_name: String,
        message: String,
    },
    MssqlWrite {
        source: Error,
    },
    MssqlWritePhase {
        context: Box<MssqlWriteFailureContext>,
        message: String,
    },
    MssqlBatchSchemaValidation {
        context: Box<MssqlWriteFailureContext>,
        source: Error,
    },
    MssqlWorkflowPlanning {
        message: String,
    },
}

Error type used by DeltaFunnel APIs.

Variants

Config

Caller configuration is invalid.

Fields

message: String

Sanitized message suitable for logs and Python-facing errors.

InvalidSourceName

A Delta source name is not valid for registration.

Fields

name: String

Caller-provided source name.

reason: &'static str

Sanitized reason for the validation failure.

DuplicateSourceName

Two configured Delta sources use the same registration name.

Fields

name: String

Caller-provided duplicate source name.

InvalidSourceUri

A Delta source URI is not valid for snapshot loading.

Fields

reason: &'static str

Sanitized reason for the validation failure.

DeltaSourceEngine

A Delta source engine could not be constructed.

Fields

reason: &'static str

Sanitized reason for the engine construction failure.

DeltaSnapshotLoad

A Delta snapshot could not be loaded.

Fields

reason: String

Sanitized reason for the snapshot load failure.

DeltaProtocolCompatibility

A Delta source requires an unsupported reader protocol.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

snapshot_version: u64

Resolved Delta snapshot version.

reason: String

Sanitized reason for the compatibility failure.

DeltaSourceSchema

A Delta source schema could not be exposed to the query engine.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

reason: String

Sanitized reason for the schema failure.

DataFusionRegistration

A Delta source could not be registered with DataFusion.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

reason: String

Sanitized reason for the registration failure.

SqlTable

Lazy SQL-derived table planning or alias registration failed.

Fields

phase: SqlTablePhase

Session SQL table phase that failed.

message: String

Sanitized reason for the failure.

DeltaScanProjection

A Delta provider scan projection could not be planned.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

reason: String

Sanitized reason for the projection failure.

DeltaScanFilter

A pushed Delta provider scan filter could not be planned safely.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

reason: String

Sanitized reason for the filter failure.

DeltaScanConstruction

A Delta kernel scan could not be constructed.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

source: Box<Error>

Kernel scan construction failure.

DeltaScanMetadataExpansion

Delta scan metadata could not be expanded from kernel scan planning.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

snapshot_version: u64

Resolved Delta snapshot version.

source: Box<Error>

Kernel scan metadata expansion failure.

DeltaScanFileTaskPlanning

Delta scan metadata could not be converted into provider file tasks.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

snapshot_version: u64

Resolved Delta snapshot version.

path: String

Delta add-action path associated with the task planning failure.

reason: String

Sanitized reason for the task planning failure.

DeltaScanFileTaskPartitionPlanning

Delta scan file tasks could not be grouped into provider scan partitions.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

snapshot_version: u64

Resolved Delta snapshot version.

reason: String

Sanitized reason for the partition planning failure.

DeltaScanFileRead

A Delta scan data file could not be read through the kernel adapter.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

snapshot_version: u64

Resolved Delta snapshot version.

path: String

Delta add-action path associated with the read failure.

phase: DeltaScanFileReadPhase

Read phase associated with the failure.

source: Box<Error>

Underlying kernel read failure.

DeltaScanDeletionVector

A Delta scan deletion vector could not be loaded or consumed safely.

Fields

source_name: String

Caller-provided source name.

table_uri: String

Sanitized or sanitizable Delta table URI context.

snapshot_version: u64

Resolved Delta snapshot version.

path: String

Delta add-action path associated with the deletion-vector failure.

phase: DeltaScanDeletionVectorPhase

Deletion-vector phase associated with the failure.

source: Box<Error>

Underlying kernel deletion-vector failure.

DependencyCompatibility

A required dependency contract is unavailable or incompatible.

Fields

message: String

Sanitized message suitable for logs and Python-facing errors.

BatchPipeline

Batch pipeline setup or configuration is invalid.

Fields

phase: BatchPipelinePhase

Batch pipeline phase associated with the failure.

option: &'static str

Stable option name associated with the failure.

message: String

Sanitized message suitable for logs and Python-facing errors.

MssqlTargetConfig

SQL Server target configuration is invalid.

Fields

option: &'static str

Stable option name associated with the failure.

message: String

Sanitized message suitable for logs and Python-facing errors.

MissingMssqlConnection

A SQL Server target could not resolve a connection.

Fields

output_name: String

Selected output name associated with the target.

InvalidMssqlOutputIdentity

A selected output identity is missing or invalid for SQL Server schema planning.

Fields

output_name: String

Selected output name associated with the schema.

reason: &'static str

Stable reason for the validation failure.

DuplicateMssqlOutputField

A selected output has duplicate field names before SQL Server planning.

Fields

output_name: String

Selected output name associated with the schema.

field_name: String

Duplicate output field name.

first_index: usize

First index where the field name was seen.

duplicate_index: usize

Duplicate index where the field name was seen again.

MssqlSchemaPlanning

SQL Server schema planning failed with structured arrow-tiberius diagnostics.

Fields

output_name: String

Selected output name associated with the schema.

diagnostics: DiagnosticSet

Structured diagnostics returned by arrow-tiberius.

MssqlSchemaPlanningFailed

SQL Server schema planning failed before producing diagnostics.

Fields

output_name: String

Selected output name associated with the schema.

source: Error

Underlying arrow-tiberius planning failure.

MssqlDdlTargetIdentifier

SQL Server DDL planning failed because a target identifier was invalid.

Fields

output_name: String

Selected output name associated with the target.

source: Error

Underlying arrow-tiberius identifier validation failure.

MssqlDdlPlanning

SQL Server DDL planning failed for a DeltaFunnel-owned lifecycle reason.

Fields

output_name: String

Selected output name associated with the target.

message: String

Sanitized reason for the DDL planning failure.

MssqlLifecyclePlanning

SQL Server lifecycle planning failed for a DeltaFunnel-owned reason.

Fields

output_name: String

Selected output name associated with the target.

message: String

Sanitized reason for the lifecycle planning failure.

MssqlWrite

SQL Server batch writing failed.

Fields

source: Error

Underlying Arrow-to-TDS or Tiberius writer failure.

MssqlWritePhase

SQL Server write execution failed during a known phase.

Fields

context: Box<MssqlWriteFailureContext>

Structured, redacted failure context.

message: String

Sanitized reason for the write failure.

MssqlBatchSchemaValidation

SQL Server output batch schema validation failed.

Fields

context: Box<MssqlWriteFailureContext>

Structured, redacted failure context.

source: Error

Underlying arrow-tiberius schema validation failure.

MssqlWorkflowPlanning

SQL Server multi-output workflow planning failed before output writes.

Fields

message: String

Sanitized reason for the workflow planning failure.

Trait Implementations

impl Debug for DeltaFunnelError

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

Formats the value using the given formatter.

impl Display for DeltaFunnelError

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

Formats the value using the given formatter.

impl Error for DeltaFunnelError

where Self: Debug + Display,

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 ErrorCompat for DeltaFunnelError

fn backtrace(&self) -> Option<&Backtrace>

Returns a Backtrace that may be printed.

fn iter_chain(&self) -> ChainCompat<'_, '_>

where Self: AsErrorSource,

Returns an iterator for traversing the chain of errors, starting with the current error and continuing with recursive calls to Error::source.

impl From<DeltaFunnelError> for DataFusionError

fn from(error: DeltaFunnelError) -> Self

Converts to this type from the input type.