lib/searchkick/process_queue_job.rb in searchkick-4.6.3 vs lib/searchkick/process_queue_job.rb in searchkick-5.0.0
- old
+ new
@@ -1,14 +1,15 @@
module Searchkick
class ProcessQueueJob < ActiveJob::Base
queue_as { Searchkick.queue_name }
def perform(class_name:, index_name: nil, inline: false)
- model = class_name.constantize
+ model = Searchkick.load_model(class_name)
+ index = model.searchkick_index(name: index_name)
limit = model.searchkick_options[:batch_size] || 1000
loop do
- record_ids = model.searchkick_index(name: index_name).reindex_queue.reserve(limit: limit)
+ record_ids = index.reindex_queue.reserve(limit: limit)
if record_ids.any?
batch_options = {
class_name: class_name,
record_ids: record_ids.uniq,
index_name: index_name