Add load id to metrics

dlt-hub · Mar 5, 2024 · b5a5f84 · b5a5f84
1 parent 500942a
commit b5a5f84
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dlt/common/pipeline.py b/dlt/common/pipeline.py
@@ -108,7 +108,9 @@ def asdict(self) -> DictStrAny:
         if self.metrics:
             d["started_at"] = self.started_at
             d["finished_at"] = self.finished_at
-            d["metrics"] = [dict(metric) for metric in self.metrics.values()]
+            d["metrics"] = [
+                {**dict(metric), "load_id": load_id} for load_id, metric in self.metrics.items()
+            ]
         return d
 
     def __str__(self) -> str: