implemented base interface

[sql.git] / libexec / daily_afs_backups

diff --git a/libexec/daily_afs_backups b/libexec/daily_afs_backups
index 4346483d6cab7b774d436635021105c5ef688508..08b9535916ef74d53a31fe40273a3d8add24cabc 100755 (executable)
--- a/libexec/daily_afs_backups
+++ b/libexec/daily_afs_backups
@@ -1,7 +1,7 @@
 #!/usr/bin/python
 
 import os, sys, time
-import sql.db
+from sql import db
 from sql.util import new_cursor, get_dbs, db_backup_pre, db_backup_mkdir
 from Queue import Queue, Empty
 import threading
@@ -21,11 +21,11 @@ def consumer():
         try:
             next = queue.get(timeout=3)
             print next[0] + ':',
-            log = sql.db.Backup.get_by(db=next[0])
+            log = db.Backup.get_by(db=next[0])
             if not log:
-                log = sql.db.Backup(db=next[0])
+                log = db.Backup(db=next[0])
             log.dump_path = next[1]
-            log.dump_date = sql.db.func.now()
+            log.dump_date = db.func.now()
             db_backup_mkdir(next[1])
             args = ['mysqldump', next[0]]
             args.extend(MYSQLDUMP_ARGS)
@@ -40,7 +40,7 @@ def consumer():
                 log.dump_errnum = None
                 log.dump_errstr = None
             log.save_or_update()
-            sql.db.session.flush()
+            db.session.flush()
             print 'Done'
         except (KeyboardInterrupt, SystemExit):
             break
@@ -54,9 +54,9 @@ t_consumer.start()
 def producer():
     c = new_cursor('mysqldump')
     for db in get_dbs(c):
-        log = sql.db.Backup.get_by(db=db)
+        log = db.Backup.get_by(db=db)
         if not log:
-            log = sql.db.Backup(db=db)
+            log = 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
@@ -68,9 +68,9 @@ def producer():
             log.skip_date = None
         else:
             log.skip_reason = d[1]
-            log.skip_date = sql.db.func.now()
+            log.skip_date = db.func.now()
         log.save_or_update()
-        #sql.db.session.flush()
+        #db.session.flush()
 
 try:
     producer()