Switch return with can_yield

xethorn · Feb 19, 2015 · c541836 · c541836
1 parent b22f689
commit c541836
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/garcon/activity.py b/garcon/activity.py
@@ -360,17 +360,21 @@ def find_available_activities(flow, history, context):
                 raise Exception(
                     'The activity failures has exceeded its retry limit.')
 
+        can_yield = True
         for requirement in instance.activity_worker.requires:
             require_history = history.get(requirement.name)
 
             if not require_history:
-                return
+                can_yield = False
+                break
 
             for requirement_evt in require_history.values():
                 if not ACTIVITY_COMPLETED in requirement_evt:
-                    return
+                    can_yield = False
+                    break
 
-        yield instance
+        if can_yield:
+            yield instance
 
 
 def find_uncomplete_activities(flow, history, context):