summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-03-14 17:43:38 +0100
committerschneefux <schneefux+commit@schneefux.xyz>2017-03-14 17:43:38 +0100
commit7ced841aa44a7dd7bd2d3a68ceb989ef488ce441 (patch)
tree9dbe59970d2ed6b3d6820ae87da3484a7d4deff3
parentd6f36879af6de9af26a99a9c518152091a1ff1fc (diff)
parent9b684e7bc573ae560e9660b9c5346d5dbf262e9a (diff)
downloadjoblib-7ced841aa44a7dd7bd2d3a68ceb989ef488ce441.tar.gz
joblib-7ced841aa44a7dd7bd2d3a68ceb989ef488ce441.zip
Merge branch 'develop' of https://github.com/vainglorygame/joblib into developHEADmaster1.2.0
-rw-r--r--worker.py2
1 files changed, 1 insertions, 1 deletions
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):