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