From 7146b0446406aab8b287f234af7831467468e6b9 Mon Sep 17 00:00:00 2001 From: Lucas Cardozo Date: Thu, 18 Apr 2019 18:12:49 -0300 Subject: [PATCH] mark as "task done" for syncronized tasks --- workflow/patterns/controlflow.py | 1 + 1 file changed, 1 insertion(+) diff --git a/workflow/patterns/controlflow.py b/workflow/patterns/controlflow.py index 48663b3..26dbc22 100644 --- a/workflow/patterns/controlflow.py +++ b/workflow/patterns/controlflow.py @@ -507,3 +507,4 @@ def __init__(self, itemq, *args, **kwargs): def run(self): call = self.itemq.get() call() + self.itemq.task_done()