chewy_cursor.rb

module ChewyPostgresCursorAdapter

  def import_scope(scope, options)
    result = true

    objects = []
    index = 0
    scope.each_instance(block_size: options[:batch_size]) do |instance|
      objects << instance

      if index >= options[:batch_size]
        result &= yield grouped_objects(objects)
        objects = []
        index = 0
      end
      index += 1
    end
    result &= yield grouped_objects(objects)

    result
  end

end

Chewy::Type::Adapter::ActiveRecord.prepend(ChewyPostgresCursorAdapter)