DeciderWorker: pass task_list to new executors

Signed-off-by: Yves Bastide <yves@botify.com>

Author: ybastide

simpleflow/swf/process/decider/base.py

@@ -166,7 +166,7 @@ def decide(self, decision_response):
         :rtype: list[swf.models.decision.base.Decision]
         """
         worker = DeciderWorker(self.domain, self._workflow_executors)
-        decisions = worker.decide(decision_response)
+        decisions = worker.decide(decision_response, self.task_list)
         return decisions
 
 
@@ -183,12 +183,14 @@ def __init__(self, domain, workflow_executors):
         self._domain = domain
         self._workflow_executors = workflow_executors
 
-    def decide(self, decision_response):
+    def decide(self, decision_response, task_list):
         """
         Delegate the decision to the executor, loading it if needed.
 
         :param decision_response: an object wrapping the PollForDecisionTask response.
         :type  decision_response: swf.responses.Response
+        :param task_list:
+        :type task_list: Optional[str]
 
         :returns: the decisions.
         :rtype: list[swf.models.decision.base.Decision]
@@ -202,6 +204,7 @@ def decide(self, decision_response):
             workflow_executor = helpers.load_workflow_executor(
                 self._domain,
                 workflow_name,
+                task_list=task_list,
             )
             self._workflow_executors[workflow_name] = workflow_executor
         try: