lib/searchkick/process_queue_job.rb in searchkick-2.0.4 vs lib/searchkick/process_queue_job.rb in searchkick-2.1.0

@@ -3,10 +3,10 @@
     queue_as :searchkick
 
     def perform(class_name:)
       model = class_name.constantize
 
-      limit = 1000
+      limit = model.searchkick_index.options[:batch_size] || 1000
       record_ids = Searchkick::ReindexQueue.new(model.searchkick_index.name).reserve(limit: limit)
       if record_ids.any?
         Searchkick::ProcessBatchJob.perform_later(
           class_name: model.name,
           record_ids: record_ids