summaryrefslogtreecommitdiff
path: root/scripts/data_maintainer.py
diff options
context:
space:
mode:
authormartinko2013-03-04 09:48:02 +0000
committermartinko2013-03-04 09:48:02 +0000
commit5d2fbaf63bb0ead9ce3dcc95f4d4dd1173813008 (patch)
tree815da6db792c947b592220ffbd929b251b1eaffd /scripts/data_maintainer.py
parent7beec385710edb11751267cc71fa40547670ced8 (diff)
scripts/data_maintainer.py: fixes
Diffstat (limited to 'scripts/data_maintainer.py')
-rw-r--r--scripts/data_maintainer.py8
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: