diff --git a/CHANGELOG.md b/CHANGELOG.md index e1cd8ee..38b3287 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,6 +1,7 @@ ## 3.0.3 [unreleased] - Fixed "Model Search Data" output for `debug` option +- Fixed `reindex_status` error ## 3.0.2 diff --git a/lib/searchkick/bulk_indexer.rb b/lib/searchkick/bulk_indexer.rb index 1576dac..e49d893 100644 --- a/lib/searchkick/bulk_indexer.rb +++ b/lib/searchkick/bulk_indexer.rb @@ -51,6 +51,10 @@ module Searchkick Searchkick.indexer.queue(records.map { |r| RecordData.new(index, r).update_data(method_name) }) end + def batches_left + Searchkick.with_redis { |r| r.scard(batches_key) } + end + private def import_or_update(records, method_name, async) @@ -156,10 +160,6 @@ module Searchkick end end - def batches_left - Searchkick.with_redis { |r| r.scard(batches_key) } - end - def batches_key "searchkick:reindex:#{index.name}:batches" end diff --git a/test/reindex_test.rb b/test/reindex_test.rb index cd2d1e9..015188b 100644 --- a/test/reindex_test.rb +++ b/test/reindex_test.rb @@ -40,6 +40,10 @@ class ReindexTest < Minitest::Test index.refresh assert_equal 1, index.total_docs + if defined?(Redis) + assert Searchkick.reindex_status(reindex[:name]) + end + Product.searchkick_index.promote(reindex[:index_name]) assert_search "product", ["Product A"] end -- libgit2 0.21.0