backups: keep less monthlys

[sql.git] / libexec / daily_afs_backups

diff --git a/libexec/daily_afs_backups b/libexec/daily_afs_backups
index 784a5798b1aab2fe19ea13cbad3587dd01b4c07a..c7c6288a1199442ffbd4321628d7c4d5bfff6e72 100755 (executable)
--- a/libexec/daily_afs_backups
+++ b/libexec/daily_afs_backups
@@ -20,6 +20,7 @@ def consumer():
     while True:
         try:
             next = queue.get(timeout=3)
+            print "Consuming", next
             #print next[0] + ':',
             log = db.Backup.get_by(db=next[0])
             if not log:
@@ -36,6 +37,8 @@ def consumer():
                 p1.wait()
                 err = p0.stderr.read()
             except Exception, e:
+                print "Error on", next
+                print e
                 err = str(e)
             if len(err):
                 log.dump_errnum = p0.returncode
@@ -47,9 +50,12 @@ def consumer():
             db.session.flush()
             #print 'Done'
         except (KeyboardInterrupt, SystemExit):
+            print "Got exit request"
             break
         except Empty:
+            print "No queue."
             if finished:
+                print "Done!"
                 break
 
 t_consumer = threading.Thread(target=consumer)