Module: MailDeliveryTask::BaseDeliveryBatchJob

Extended by:
ActiveSupport::Concern
Defined in:
lib/mail_delivery_task/jobs/base_delivery_batch_job.rb

Instance Method Summary collapse

Instance Method Details

#performObject



10
11
12
13
14
15
16
# File 'lib/mail_delivery_task/jobs/base_delivery_batch_job.rb', line 10

def perform
  unless_already_executing do
    ::MailDeliveryTask::Attempt.pending.where('scheduled_at IS ? || scheduled_at < ?', nil, Time.current).find_each do |task|
      ::MailDeliveryJob.perform_later(task)
    end
  end
end