off-by-one ☹

mineo · Apr 16, 2016 · ff08810 · ff08810
1 parent a8d93be
commit ff08810
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/abzer/abzer.py b/abzer/abzer.py
@@ -135,7 +135,7 @@ async def run(self):
         if to_process:
             tasks = []
             tasks.append(self.producer(to_process))
-            for i in range(0, self.num_processes + 1):
+            for i in range(0, self.num_processes):
                 tasks.append(self.consumer())
             tasks.append(self.queue.join())
             await asyncio.gather(*tasks)