dlt.common.storages.job_metrics
metrics_by_job
def metrics_by_job(
files: Iterable[DataWriterMetrics]
) -> Dict[ParsedLoadJobFileName, DataWriterMetrics]
Keys the metrics of job files by their parsed file name. Does not access the files.
metrics_by_table
def metrics_by_table(
job_metrics: Mapping[ParsedLoadJobFileName, DataWriterMetrics]
) -> Dict[str, DataWriterMetrics]
Sums the metrics of job files by table
merge_metrics
def merge_metrics(
metrics_maps: Iterable[Mapping[str, DataWriterMetrics]]
) -> Dict[str, DataWriterMetrics]
Sums metrics with the same key, ie. tables or resources of several load packages