lib/dirty_pipeline/transaction.rb in dirty_pipeline-0.6.4 vs lib/dirty_pipeline/transaction.rb in dirty_pipeline-0.7.0
- old
+ new
@@ -9,9 +9,10 @@
end
def call
pipeline.schedule_cleanup
+ # Split attempts config and event dispatching
destination, action, max_attempts_count =
pipeline.find_transition(event.transition)
.values_at(:to, :action, :attempts)
storage.commit!(event)