Pass execution_id down to ItemProcessor states

ManageIQ · Oct 4, 2024 · 8bf874c · 8bf874c
1 parent ed854ce
commit 8bf874c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)