lib/dirty_pipeline/base.rb in dirty_pipeline-0.8.2 vs lib/dirty_pipeline/base.rb in dirty_pipeline-0.8.3

@@ -129,12 +129,13 @@
       attempt_retry ? event.attempt_retry! : event.start!
 
       # dispatch event?
       Transaction.new(self, event).call do |destination, action, *args|
         state_changes = process_action(action, event, *args)
+        event.assign_changes(state_changes)
         next if status.failure?
-        Success(event, state_changes, destination)
+        Success(event, destination)
       end
       call_next
 
       self
     end
@@ -174,11 +175,11 @@
     def Failure(event, cause, type:)
       event.failure!
       @status = Status.failure(cause, tag: type)
     end
 
-    def Success(event, changes, destination)
-      event.complete(changes, destination)
+    def Success(event, destination)
+      event.complete(destination)
       @status = Status.success(subject)
     end
   end
 end