method
enqueue_all
rails latest stable - Class:
ActiveJob::LogSubscriber
enqueue_all(event)public
No documentation available.
# File activejob/lib/active_job/log_subscriber.rb, line 49
def enqueue_all(event)
info do
jobs = event.payload[:jobs]
adapter = event.payload[:adapter]
enqueued_count = event.payload[:enqueued_count]
if enqueued_count == jobs.size
enqueued_jobs_message(adapter, jobs)
elsif jobs.any?(&:successfully_enqueued?)
enqueued_jobs = jobs.select(&:successfully_enqueued?)
failed_enqueue_count = jobs.size - enqueued_count
if failed_enqueue_count == 0
enqueued_jobs_message(adapter, enqueued_jobs)
else
"#{enqueued_jobs_message(adapter, enqueued_jobs)}. " "Failed enqueuing #{failed_enqueue_count} #{'job'.pluralize(failed_enqueue_count)}"
end
else
failed_enqueue_count = jobs.size - enqueued_count
"Failed enqueuing #{failed_enqueue_count} #{'job'.pluralize(failed_enqueue_count)} " "to #{ActiveJob.adapter_name(adapter)}"
end
end
end