Module: BulkProcessor::BackEnd

Defined in:
lib/bulk_processor/back_end.rb,
lib/bulk_processor/back_end/dynosaur.rb,
lib/bulk_processor/back_end/active_job.rb,
lib/bulk_processor/back_end/dynosaur/split_csv_task.rb,
lib/bulk_processor/back_end/active_job/split_csv_job.rb,
lib/bulk_processor/back_end/dynosaur/process_csv_task.rb,
lib/bulk_processor/back_end/active_job/process_csv_job.rb

Defined Under Namespace

Classes: ActiveJob, Dynosaur

Class Method Summary collapse

Class Method Details

.start(processor_class:, payload:, key:, num_processes: 1) ⇒ Object 



4
5
6
7
8
9
10
11
 
# File 'lib/bulk_processor/back_end.rb', line 4

def start(processor_class:, payload:, key:, num_processes: 1)
  back_end = back_end_class.new(
    processor_class: processor_class,
    payload: payload,
    key: key
  )
  num_processes > 1 ? back_end.split(num_processes) : back_end.start
end