Skip to content

Commit

Permalink
Place bounded trie lineage metrics under a new name.
Browse files Browse the repository at this point in the history
This avoids any potential complexities with mixing old and new
metrics with the same name but different types (e.g. after a
streaming update across an sdk upgrade).
  • Loading branch information
robertwb committed Jan 2, 2025
1 parent badbce0 commit 3210b47
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions sdks/python/apache_beam/metrics/metric.py
Original file line number Diff line number Diff line change
Expand Up @@ -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),
Expand Down

0 comments on commit 3210b47

Please sign in to comment.