diff --git a/elasticsearch-model/lib/elasticsearch/model/adapters/mongoid.rb b/elasticsearch-model/lib/elasticsearch/model/adapters/mongoid.rb index 51c9e1be3..7c4f18a16 100644 --- a/elasticsearch-model/lib/elasticsearch/model/adapters/mongoid.rb +++ b/elasticsearch-model/lib/elasticsearch/model/adapters/mongoid.rb @@ -66,7 +66,7 @@ def __find_in_batches(options={}, &block) options[:batch_size] ||= 1_000 items = [] - all.each do |item| + all.no_timeout.each do |item| items << item if items.length % options[:batch_size] == 0