From c215faacda3a645a84a013b010bb5f371eb7b621 Mon Sep 17 00:00:00 2001 From: Max Tobelem <100571794+max-tobelem@users.noreply.github.com> Date: Wed, 19 Nov 2025 14:59:25 +0100 Subject: [PATCH 1/2] feat: Add task_list to context --- simpleflow/swf/process/worker/base.py | 1 + 1 file changed, 1 insertion(+) diff --git a/simpleflow/swf/process/worker/base.py b/simpleflow/swf/process/worker/base.py index e3a5ca67..29c95b5e 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["task_list"] = poller.task_list if input.get("meta", {}).get("binaries"): download_binaries(input["meta"]["binaries"]) result = ActivityTask( From 11788c03666fd8e5a3580ef8b7fd1d40a14862cd Mon Sep 17 00:00:00 2001 From: Max Tobelem <100571794+max-tobelem@users.noreply.github.com> Date: Wed, 19 Nov 2025 16:31:19 +0100 Subject: [PATCH 2/2] review: From task_list to activity_task_list --- simpleflow/swf/process/worker/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/simpleflow/swf/process/worker/base.py b/simpleflow/swf/process/worker/base.py index 29c95b5e..83720782 100644 --- a/simpleflow/swf/process/worker/base.py +++ b/simpleflow/swf/process/worker/base.py @@ -142,7 +142,7 @@ def process( kwargs = input.get("kwargs", {}) context = sanitize_activity_context(task.context) context["domain_name"] = poller.domain.name - context["task_list"] = poller.task_list + context["activity_task_list"] = poller.task_list if input.get("meta", {}).get("binaries"): download_binaries(input["meta"]["binaries"]) result = ActivityTask(