common.metrics
StepMetrics Objects
class StepMetrics(TypedDict)
Metrics for particular package processed in particular pipeline step
started_at
Start of package processing
finished_at
End of package processing
ExtractMetrics Objects
class ExtractMetrics(StepMetrics)
job_metrics
Metrics collected per job id during writing of job file
table_metrics
Job metrics aggregated by table
resource_metrics
Job metrics aggregated by resource
dag
A resource dag where elements of the list are graph edges
hints
Hints passed to the resources
NormalizeMetrics Objects
class NormalizeMetrics(StepMetrics)
job_metrics
Metrics collected per job id during writing of job file
table_metrics
Job metrics aggregated by table