Print queue size while flushing

2025-07-01 13:57:02 -04:00 · 2012-01-15 12:58:38 -05:00
parent 7e8cc4e40b
commit 5ab529bcde
1 changed files with 1 additions and 0 deletions
--- 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):