class BatchProcessor::Processors::Sequential

Public Class Methods

disable_retries?() click to toggle source
# File lib/batch_processor/processors/sequential.rb, line 11
def disable_retries?
  true
end

Public Instance Methods

process_collection_item(item) click to toggle source
# File lib/batch_processor/processors/sequential.rb, line 16
def process_collection_item(item)
  job = batch.job_class.new(item)
  job.batch_id = batch.batch_id
  job.perform_now
rescue StandardError => exception
  raise exception unless continue_after_exception
end

Private Instance Methods

iterator_method() click to toggle source
# File lib/batch_processor/processors/sequential.rb, line 26
def iterator_method
  sorted ? :each : super
end