Commit d8ce46d4d582fb07fa388e6f71eb9d8488bea1ed
1 parent
dcaa4c09
Exists in
master
and in
19 other branches
Cleaner queue code [skip ci]
Showing
1 changed file
with
1 additions
and
1 deletions
Show diff stats
lib/searchkick/process_queue_job.rb
| @@ -6,7 +6,7 @@ module Searchkick | @@ -6,7 +6,7 @@ module Searchkick | ||
| 6 | model = class_name.constantize | 6 | model = class_name.constantize |
| 7 | 7 | ||
| 8 | limit = model.searchkick_index.options[:batch_size] || 1000 | 8 | limit = model.searchkick_index.options[:batch_size] || 1000 |
| 9 | - record_ids = Searchkick::ReindexQueue.new(model.searchkick_index.name).reserve(limit: limit) | 9 | + record_ids = model.searchkick_index.reindex_queue.reserve(limit: limit) |
| 10 | if record_ids.any? | 10 | if record_ids.any? |
| 11 | Searchkick::ProcessBatchJob.perform_later( | 11 | Searchkick::ProcessBatchJob.perform_later( |
| 12 | class_name: model.name, | 12 | class_name: model.name, |