We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 077e777 commit 6b1b007Copy full SHA for 6b1b007
sdks/python/apache_beam/testing/load_tests/dataflow_cost_benchmark.py
@@ -192,9 +192,7 @@ def _get_throughput_metrics(
192
) -> dict[str, float]:
193
"""Query Cloud Monitoring for per-PCollection throughput."""
194
name = (
195
- pcollection_name
196
- if pcollection_name is not None
197
- else self.pcollection)
+ pcollection_name if pcollection_name is not None 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