lib/dirty_pipeline/redis/storage.rb in dirty_pipeline-0.8.3 vs lib/dirty_pipeline/redis/storage.rb in dirty_pipeline-0.9.0

@@ -46,10 +46,10 @@
       def status
         store["status"]
       end
 
       def commit!(event)
-        store["status"] = event.destination     if event.destination
+        store["status"] = event.destination     if event.success?
         store["state"].merge!(event.changes)    unless event.changes.to_h.empty?
 
         error = {}
         error = event.error.to_h unless event.error.to_h.empty?
         store["errors"][event.id] = error