Function load_trace

dlt/pipeline/trace.py:338–351

(trace_dir: str, ignore_errors: bool = True)

def load_trace(trace_dir: str, ignore_errors: bool = True) -> PipelineTrace:
    try:
        with open(os.path.join(trace_dir, TRACE_FILE_NAME), mode="rb") as f:
            return pickle.load(f)  # type: ignore
    except FileNotFoundError:
        # file not found return no trace
        pass
    except Exception as ex:
        # we do not guarantee traces backward compat
        if not ignore_errors:
            raise
        logger.warning(f"Error when loading trace at {trace_dir}: %s" % ex)

    return None


def get_trace_file_path(pipelines_dir: str, pipeline_name: str) -> str: