X-Git-Url: https://git.openstreetmap.org./nominatim.git/blobdiff_plain/5016eace34b5924d752ee0eb889ce9a2f663e78e..a6dab5e300de9c5664f714eb2c9290d18f01067f:/nominatim/indexer/progress.py?ds=sidebyside diff --git a/nominatim/indexer/progress.py b/nominatim/indexer/progress.py index 99120673..b758e10d 100644 --- a/nominatim/indexer/progress.py +++ b/nominatim/indexer/progress.py @@ -1,7 +1,9 @@ # SPDX-License-Identifier: GPL-2.0-only # -# This file is part of Nominatim. -# Copyright (C) 2020 Sarah Hoffmann +# This file is part of Nominatim. (https://nominatim.org) +# +# Copyright (C) 2022 by the Nominatim developer community. +# For a full list of authors see the git log. """ Helpers for progress logging. """ @@ -26,7 +28,7 @@ class ProgressLogger: self.done_places = 0 self.rank_start_time = datetime.now() self.log_interval = log_interval - self.next_info = INITIAL_PROGRESS if LOG.isEnabledFor(logging.INFO) else total + 1 + self.next_info = INITIAL_PROGRESS if LOG.isEnabledFor(logging.WARNING) else total + 1 def add(self, num=1): """ Mark `num` places as processed. Print a log message if the @@ -47,9 +49,9 @@ class ProgressLogger: places_per_sec = self.done_places / done_time eta = (self.total_places - self.done_places) / places_per_sec - LOG.info("Done %d in %d @ %.3f per second - %s ETA (seconds): %.2f", - self.done_places, int(done_time), - places_per_sec, self.name, eta) + LOG.warning("Done %d in %d @ %.3f per second - %s ETA (seconds): %.2f", + self.done_places, int(done_time), + places_per_sec, self.name, eta) self.next_info += int(places_per_sec) * self.log_interval @@ -57,8 +59,14 @@ class ProgressLogger: """ Print final statistics about the progress. """ rank_end_time = datetime.now() - diff_seconds = (rank_end_time-self.rank_start_time).total_seconds() + + if rank_end_time == self.rank_start_time: + diff_seconds = 0 + places_per_sec = self.done_places + else: + diff_seconds = (rank_end_time - self.rank_start_time).total_seconds() + places_per_sec = self.done_places / diff_seconds LOG.warning("Done %d/%d in %d @ %.3f per second - FINISHED %s\n", self.done_places, self.total_places, int(diff_seconds), - self.done_places/diff_seconds, self.name) + places_per_sec, self.name)