lib/dirty_pipeline/base.rb in dirty_pipeline-0.6.1 vs lib/dirty_pipeline/base.rb in dirty_pipeline-0.6.2

@@ -154,20 +154,20 @@
     end
 
     def interupt_on_error(event)
       return unless (fail_cause = catch(:fail_transition) { yield; nil })
       Failure(event, fail_cause, type: :error)
+      throw :abort_transaction, true
     end
 
     def find_subject_args
       subject.id
     end
 
     def Failure(event, cause, type:)
       railway.switch_to(:undo)
       event.failure!
       @status = Status.failure(cause, tag: type)
-      throw :abort_transaction, true
     end
 
     def Success(event, changes, destination)
       event.complete(changes, destination)
       @status = Status.success(subject)