diff options
author | martinko | 2013-03-04 09:48:02 +0000 |
---|---|---|
committer | martinko | 2013-03-04 09:48:02 +0000 |
commit | 5d2fbaf63bb0ead9ce3dcc95f4d4dd1173813008 (patch) | |
tree | 815da6db792c947b592220ffbd929b251b1eaffd /scripts/data_maintainer.py | |
parent | 7beec385710edb11751267cc71fa40547670ced8 (diff) |
scripts/data_maintainer.py: fixes
Diffstat (limited to 'scripts/data_maintainer.py')
-rw-r--r-- | scripts/data_maintainer.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/scripts/data_maintainer.py b/scripts/data_maintainer.py index 617960d4..8aa2bce6 100644 --- a/scripts/data_maintainer.py +++ b/scripts/data_maintainer.py @@ -165,9 +165,11 @@ class DataMaintainer (skytools.DBScript): self.send_stats() if len(res) < self.fetchcnt: break - if self.looping == 0: + if self.last_sigint: self.log.info("Exiting on user request") break + if self.commit_delay > 0.0: + time.sleep(self.commit_delay) if time.time() - lap_time > 60.0: # if one minute has passed print running totals self.log.info("--- Running count: %s duration: %s ---", total_count, datetime.timedelta(0, round(time.time() - started))) @@ -218,10 +220,8 @@ class DataMaintainer (skytools.DBScript): else: count += 1 self.stat_increase("count") - if self.looping == 0: + if self.last_sigint: break - if self.commit_delay > 0.0: - time.sleep(self.commit_delay) return count, item except: # process has crashed, run sql_crash and re-raise the exception if self.sql_crash: |