Skip to content

Commit 24d92fe

Browse files
committed
correct scalar access
1 parent a7a4015 commit 24d92fe

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -206,8 +206,8 @@ def _get_metric_value(self, metric):
206206
print("Distribution: ", metric.distribution)
207207
if metric.scalar is not None:
208208
# This will always be a single value if there is any data in the field.
209-
print("Treating as scalar: ", metric.scalar.number_value)
210-
return metric.scalar.number_value
209+
print("Treating as scalar: ", metric.scalar)
210+
return metric.scalar
211211
elif metric.distribution is not None:
212212
print("Treating as distribution: ", metric.distribution)
213213
dist_count = metric.distribution.struct_value.fields['count'].number_value

0 commit comments

Comments
 (0)