#!/usr/bin/python
-import os, sys
+import os, sys, time
import sql.db
from sql.util import new_cursor, get_dbs, db_backup_pre, db_backup_mkdir
from Queue import Queue, Empty
log = sql.db.Backup.get_by(db=db)
if not log:
log = sql.db.Backup(db=db)
+ elif log.skip_date:
+ if time.mktime(log.skip_date.timetuple()) + 3600 > time.time():
+ # never recheck a db skipped in the past hour
+ continue
d = db_backup_pre(c, db)
if d[0]:
queue.put((db, d[1]))
log.skip_reason = d[1]
log.skip_date = sql.db.func.now()
log.save_or_update()
- sql.db.session.flush()
+ #sql.db.session.flush()
try:
producer()