X-Git-Url: http://andersk.mit.edu/gitweb/sql.git/blobdiff_plain/d152c985887511557c9493da3e9c92274da82cd0..HEAD:/libexec/daily_afs_backups

diff --git a/libexec/daily_afs_backups b/libexec/daily_afs_backups
index 784a579..c7c6288 100755
--- 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)