lib/dirty_pipeline/transaction.rb in dirty_pipeline-0.7.1 vs lib/dirty_pipeline/transaction.rb in dirty_pipeline-0.8.1

- old
+ new

@@ -17,10 +17,11 @@ .values_at(:to, :action, :attempts) storage.commit!(event) # FIXME: make configurable, now - hardcoded to AR API - subject.transaction(requires_new: true) do + # subject.transaction(requires_new: true) do + subject.transaction do with_abort_handling { yield(destination, action, *event.args) } end rescue => exception event.link_exception(exception) if max_attempts_count.to_i > event.attempts_count