Skip to content

Commit

Permalink
Fix linter errors
Browse files Browse the repository at this point in the history
  • Loading branch information
sakurai-youhei committed Nov 6, 2023
1 parent bf2953b commit 0d6d14a
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions esrally/driver/driver.py
Original file line number Diff line number Diff line change
Expand Up @@ -834,6 +834,7 @@ def joinpoint_reached(self, worker_id, worker_local_timestamp, task_allocations)
self.telemetry.on_benchmark_stop()
self.logger.info("All steps completed.")
# Some metrics store implementations return None because no external representation is required.
# pylint: disable=assignment-from-none
m = self.metrics_store.to_externalizable(clear=True)
self.logger.debug("Closing metrics store...")
self.metrics_store.close()
Expand Down Expand Up @@ -866,6 +867,7 @@ def move_to_next_task(self, workers_curr_step):
# (it doesn't matter too much if we're a few ms off).
waiting_period = 1.0
# Some metrics store implementations return None because no external representation is required.
# pylint: disable=assignment-from-none
m = self.metrics_store.to_externalizable(clear=True)
self.driver_actor.on_task_finished(m, waiting_period)
# Using a perf_counter here is fine also in the distributed case as we subtract it from `master_received_msg_at` making it
Expand Down

0 comments on commit 0d6d14a

Please sign in to comment.