From 9b684e7bc573ae560e9660b9c5346d5dbf262e9a Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 14 Mar 2017 17:42:49 +0100
Subject: pull batches until no jobs are available

---
 worker.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/worker.py b/worker.py
index 004055a..c27d95e 100644
--- a/worker.py
+++ b/worker.py
@@ -53,6 +53,7 @@ class Worker(object):
 
         if len(jobs) == 0:
             logging.debug("no jobs")
+            self._need_update = False
             return
 
         await self._windup()
@@ -104,7 +105,6 @@ class Worker(object):
             while not self._need_update:
                 await asyncio.sleep(0.01)
             logging.debug("polling")
-            self._need_update = False
             await self.poll(batchlimit)
 
     async def start(self, batchlimit=1):
-- 
cgit v1.3.1