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()