diff --git a/simpleflow/swf/process/worker/base.py b/simpleflow/swf/process/worker/base.py index e3a5ca67..83720782 100644 --- a/simpleflow/swf/process/worker/base.py +++ b/simpleflow/swf/process/worker/base.py @@ -142,6 +142,7 @@ def process( kwargs = input.get("kwargs", {}) context = sanitize_activity_context(task.context) context["domain_name"] = poller.domain.name + context["activity_task_list"] = poller.task_list if input.get("meta", {}).get("binaries"): download_binaries(input["meta"]["binaries"]) result = ActivityTask(