diff --git a/lib/searchkick/process_queue_job.rb b/lib/searchkick/process_queue_job.rb index 5f925f6..dce50a6 100644 --- a/lib/searchkick/process_queue_job.rb +++ b/lib/searchkick/process_queue_job.rb @@ -9,13 +9,18 @@ module Searchkick loop do record_ids = model.searchkick_index(name: index_name).reindex_queue.reserve(limit: limit) if record_ids.any? - perform_method = inline ? :perform_now : :perform_later - Searchkick::ProcessBatchJob.send( - perform_method, + batch_options = { class_name: class_name, record_ids: record_ids, index_name: index_name - ) + } + + if inline + Searchkick::ProcessBatchJob.new.perform(**batch_options) + else + Searchkick::ProcessBatchJob.perform_later(**batch_options) + end + # TODO when moving to reliable queuing, mark as complete end break unless record_ids.size == limit -- libgit2 0.21.0