We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 331aa64 commit 077e777Copy full SHA for 077e777
sdks/python/apache_beam/testing/load_tests/dataflow_cost_benchmark.py
@@ -191,7 +191,10 @@ def _get_throughput_metrics(
191
pcollection_name: Optional[str] = None,
192
) -> dict[str, float]:
193
"""Query Cloud Monitoring for per-PCollection throughput."""
194
- name = pcollection_name if pcollection_name is not None else self.pcollection
+ name = (
195
+ pcollection_name
196
+ if pcollection_name is not None
197
+ else self.pcollection)
198
interval = monitoring_v3.TimeInterval(
199
start_time=start_time, end_time=end_time)
200
aggregation = monitoring_v3.Aggregation(
0 commit comments