From 69055ed679f543de11524e7a310838311831d95a Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Mon, 6 Mar 2017 20:48:44 +0100
Subject: windup after acquiring, don't leak connections

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

(limited to 'worker.py')

diff --git a/worker.py b/worker.py
index 27fd7d8..2115847 100644
--- a/worker.py
+++ b/worker.py
@@ -39,7 +39,6 @@ class Worker(object):
     async def run(self, batchlimit=1):
         """Start jobs forever."""
         while True:
-            await self._windup()
             jobs = await self._queue.acquire(jobtype=self._jobtype,
                                        length=batchlimit)
 
@@ -48,6 +47,7 @@ class Worker(object):
                 # nothing to do
                 continue
 
+            await self._windup()
             error = None
             try:
                 for jobid, payload, priority in jobs:
-- 
cgit v1.3.1