while True:
try:
next = queue.get(timeout=3)
- print next[0] + ':',
+ #print next[0] + ':',
log = db.Backup.get_by(db=next[0])
if not log:
log = db.Backup(db=next[0])
log.dump_errstr = None
log.save_or_update()
db.session.flush()
- print 'Done'
+ #print 'Done'
except (KeyboardInterrupt, SystemExit):
break
except Empty:
log = db.Backup.get_by(db=db)
if not log:
log = db.Backup(db=db)
- elif log.skip_date:
+ elif log.skip_date and log.skip_date.timetuple:
if time.mktime(log.skip_date.timetuple()) + 3600 > time.time():
# never recheck a db skipped in the past hour
continue