lib/floe/workflow/states/input_output_mixin.rb in floe-0.11.0 vs lib/floe/workflow/states/input_output_mixin.rb in floe-0.11.3

@@ -2,26 +2,26 @@
 
 module Floe
   class Workflow
     module States
       module InputOutputMixin
-        def process_input(input)
-          input = input_path.value(context, input)
+        def process_input(context)
+          input = input_path.value(context, context.input)
           input = parameters.value(context, input) if parameters
           input
         end
 
-        def process_output(input, results)
-          return input if results.nil?
+        def process_output(context, results)
+          return context.input.dup if results.nil?
           return if output_path.nil?
 
           results = result_selector.value(context, results) if @result_selector
           if result_path.payload.start_with?("$.Credentials")
-            credentials = result_path.set(workflow.credentials, results)["Credentials"]
-            workflow.credentials.merge!(credentials)
-            output = input
+            credentials = result_path.set(context.credentials, results)["Credentials"]
+            context.credentials.merge!(credentials)
+            output = context.input.dup
           else
-            output = result_path.set(input, results)
+            output = result_path.set(context.input.dup, results)
           end
 
           output_path.value(context, output)
         end
       end