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