diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-14 17:43:38 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-14 17:43:38 +0100 |
| commit | 7ced841aa44a7dd7bd2d3a68ceb989ef488ce441 (patch) | |
| tree | 9dbe59970d2ed6b3d6820ae87da3484a7d4deff3 | |
| parent | d6f36879af6de9af26a99a9c518152091a1ff1fc (diff) | |
| parent | 9b684e7bc573ae560e9660b9c5346d5dbf262e9a (diff) | |
| download | joblib-1.2.0.tar.gz joblib-1.2.0.zip | |
| -rw-r--r-- | worker.py | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -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): |
