Module: Chewy::Type::Import

Extended by:

ActiveSupport::Concern

Included in:

Chewy::Type

Defined in:

lib/chewy/type/import.rb,
lib/chewy/type/import/routine.rb,
lib/chewy/type/import/bulk_builder.rb,
lib/chewy/type/import/bulk_request.rb,
lib/chewy/type/import/journal_builder.rb

Defined Under Namespace

Modules: ClassMethods Classes: BulkBuilder, BulkRequest, JournalBuilder, Routine

Constant Summary

IMPORT_WORKER =

lambda do |type, options, ids|
  ::Process.setproctitle("chewy import #{type}[#{::Parallel.worker_number}]")
  routine = Routine.new(type, options)
  type.adapter.import(*ids, routine.options) do |action_objects|
    routine.process(**action_objects)
  end
  {errors: routine.errors, import: routine.stats, leftovers: routine.leftovers}
end

LEFTOVERS_WORKER =

lambda do |type, options, body|
  ::Process.setproctitle("chewy import #{type}[#{::Parallel.worker_number}]")
  routine = Routine.new(type, options)
  routine.perform_bulk(body)
  routine.errors
end