pipeline.trace
SerializableResolvedValueTrace Objects
class SerializableResolvedValueTrace(NamedTuple)
Information on resolved secret and config values
asdict
def asdict() -> StrAny
A dictionary representation that is safe to load.
_PipelineStepTrace Objects
class _PipelineStepTrace(NamedTuple)
step_info
A step outcome info ie. LoadInfo
step_exception
For failing steps contains exception string
exception_traces
For failing steps contains traces of exception chain causing it
PipelineStepTrace Objects
class PipelineStepTrace(SupportsHumanize, _PipelineStepTrace)
Trace of particular pipeline step, contains timing information, the step outcome info or exception in case of failing step with custom asdict()
asdict
def asdict() -> DictStrAny
A dictionary representation of PipelineStepTrace that can be loaded with dlt
_PipelineTrace Objects
class _PipelineTrace(NamedTuple)
Pipeline runtime trace containing data on "extract", "normalize" and "load" steps and resolved config and secret values.
steps
A list of steps in the trace
resolved_config_values
A list of resolved config values
PipelineTrace Objects
class PipelineTrace(SupportsHumanize, _PipelineTrace)
asdict
def asdict() -> DictStrAny
A dictionary representation of PipelineTrace that can be loaded with dlt
merge_traces
def merge_traces(last_trace: PipelineTrace,
new_trace: PipelineTrace) -> PipelineTrace
Merges new_trace into last_trace by combining steps and timestamps. new_trace replace the last_trace if it has more than 1 step.`
get_exception_traces
def get_exception_traces(exc: BaseException,
container: Container = None) -> List[ExceptionTrace]
Gets exception trace chain and extend it with data available in Container context