Skip to content

Commit 331aa64

Browse files
committed
Fix Pylint in dataflow_cost_benchmark and singleton assertion in base_test
1 parent d261aa1 commit 331aa64

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

sdks/python/apache_beam/testing/load_tests/dataflow_cost_benchmark.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ def run(self) -> None:
9191

9292
logging.info(self.extra_metrics)
9393
self._metrics_monitor.publish_metrics(self.result, self.extra_metrics)
94-
except Exception as e:
94+
except Exception:
9595
raise
9696
finally:
9797
self.cleanup()
@@ -188,7 +188,8 @@ def _get_throughput_metrics(
188188
job_id: str,
189189
start_time: str,
190190
end_time: str,
191-
pcollection_name: Optional[str] = None) -> dict[str, float]:
191+
pcollection_name: Optional[str] = None,
192+
) -> dict[str, float]:
192193
"""Query Cloud Monitoring for per-PCollection throughput."""
193194
name = pcollection_name if pcollection_name is not None else self.pcollection
194195
interval = monitoring_v3.TimeInterval(

0 commit comments

Comments
 (0)