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:
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
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)