From 8bf874c3b8248bfc26c40d3650308aeaaf089c0d Mon Sep 17 00:00:00 2001
From: Adam Grare <adam@grare.com>
Date: Fri, 4 Oct 2024 10:23:50 -0400
Subject: [PATCH] Pass execution_id down to ItemProcessor states

---
 lib/floe/workflow/states/map.rb | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/floe/workflow/states/map.rb b/lib/floe/workflow/states/map.rb
index 998debab..7f01a553 100644
--- a/lib/floe/workflow/states/map.rb
+++ b/lib/floe/workflow/states/map.rb
@@ -54,7 +54,7 @@ def start(context)
 
           context.state["Iteration"]            = 0
           context.state["MaxIterations"]        = input.count
-          context.state["ItemProcessorContext"] = input.map { |item| Context.new(nil, :input => item.to_json).to_h }
+          context.state["ItemProcessorContext"] = input.map { |item| Context.new({"Execution" => {"Id" => context.execution["Id"]}}, :input => item.to_json).to_h }
         end
 
         def finish(context)