diff --git a/sdks/python/apache_beam/metrics/metric.py b/sdks/python/apache_beam/metrics/metric.py index 9cf42370f4b1..58a74afb9de0 100644 --- a/sdks/python/apache_beam/metrics/metric.py +++ b/sdks/python/apache_beam/metrics/metric.py @@ -339,8 +339,8 @@ class Lineage: for lineage tracking.""" LINEAGE_NAMESPACE = "lineage" - SOURCE = "sources" - SINK = "sinks" + SOURCE = "sources_v2" + SINK = "sinks_v2" _METRICS = { SOURCE: Metrics.bounded_trie(LINEAGE_NAMESPACE, SOURCE),