common.exceptions

ExceptionTrace Objects

class ExceptionTrace(TypedDict)

[view_source]

Exception trace. NOTE: we intend to change it with an extended line by line trace with code snippets

is_terminal

Says if exception is terminal if happened to a job during load step

exception_attrs

Public attributes of an exception deriving from DltException (not starting with _)

load_id

Load id if found in exception attributes

pipeline_name

Pipeline name if found in exception attributes or in the active pipeline (Container)

source_name

Source name if found in exception attributes or in Container

resource_name

Resource name if found in exception attributes

job_id

Job id if found in exception attributes

DltException Objects

class DltException(Exception)

[view_source]

__reduce__

def __reduce__() -> Any

[view_source]

Enables exceptions with parametrized constructor to be pickled

attrs

def attrs() -> Dict[str, Any]

[view_source]

Returns "public" attributes of the DltException

TerminalException Objects

class TerminalException(BaseException)

[view_source]

Marks an exception that cannot be recovered from, should be mixed in into concrete exception class

TransientException Objects

class TransientException(BaseException)

[view_source]

Marks an exception in operation that can be retried, should be mixed in into concrete exception class

TerminalValueError Objects

class TerminalValueError(ValueError, TerminalException)

[view_source]

ValueError that is unrecoverable

SignalReceivedException Objects

class SignalReceivedException(KeyboardInterrupt, TerminalException)

[view_source]

Raises when signal comes. Derives from BaseException to not be caught in regular exception handlers.

PipelineException Objects

class PipelineException(DltException)

[view_source]

__init__

def __init__(pipeline_name: str, msg: str) -> None

[view_source]

Base class for all pipeline exceptions. Should not be raised.