Replace None metric values with 0.0 in Dataflow Cost Benchmark (#33336)

apache · Dec 10, 2024 · 354e8e3 · 354e8e3
1 parent e1245d9
commit 354e8e3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sdks/python/apache_beam/testing/load_tests/dataflow_cost_benchmark.py b/sdks/python/apache_beam/testing/load_tests/dataflow_cost_benchmark.py
@@ -109,5 +109,7 @@ def _process_metrics_list(self,
       metric_key = entry.key
       metric = metric_key.metric
       if metric_key.step == '' and metric.namespace == 'dataflow/v1b3':
+        if entry.committed is None:
+          entry.committed = 0.0
         system_metrics[metric.name] = entry.committed
     return system_metrics