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

@@ -84,13 +84,16 @@
     def attempt_retry!
       @data["updated_at"] = Time.now.utc.iso8601
       @data["attempts_count"] = attempts_count + 1
     end
 
-    def complete(changes, destination)
+    def assign_changes(changes)
+      @data["changes"] = changes
+    end
+
+    def complete(destination)
       @data.merge!(
         "destination" => destination,
-        "changes" => changes,
         "updated_at" => Time.now.utc.iso8601,
         "status" => SUCCESS,
       )
     end
   end