From 5ab529bcde0362598f014b7335be383e0351eff0 Mon Sep 17 00:00:00 2001 From: Steven Robertson Date: Sun, 15 Jan 2012 12:58:38 -0500 Subject: [PATCH] Print queue size while flushing --- worker.py | 1 + 1 file changed, 1 insertion(+) diff --git a/worker.py b/worker.py index e51c1a5..48b2355 100644 --- a/worker.py +++ b/worker.py @@ -210,6 +210,7 @@ def run_jobs(r, rev, jobs): print 'Interrupt received, flushing already-dispatched frames' while pending: + print '%d...' % len(pending) yield pull(True) def client(ppath, gpaths):