lib/outboxable/polling_publisher_worker.rb in outboxable-0.1.3 vs lib/outboxable/polling_publisher_worker.rb in outboxable-0.1.4

- old
+ new

@@ -4,10 +4,10 @@ sidekiq_options queue: 'critical' def perform Outbox.pending.where(last_attempted_at: [..Time.zone.now, nil]).find_in_batches(batch_size: 100).each do |batch| batch.each do |outbox| - # This is to prevent a job from being retried too many times. Worst-case scenario is 1 minute delay in jobs. + # This is to prevent a job from being retried too many times. Worst-case scenario is 1 minute delay in jobs. outbox.update(last_attempted_at: 1.minute.from_now) Outboxable::Worker.perform_async(outbox.id) end end end