Class: BulkProcessor::BackEnd::ActiveJob

Inherits:
Object
  • Object
show all
Defined in:
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

Overview

Execute jobs via ActiveJob, e.g. Resque

Defined Under Namespace

Classes: ProcessCSVJob, ProcessCSVTask, SplitCSVJob, SplitCSVTask

Instance Method Summary collapse

Constructor Details

#initialize(processor_class:, payload:, key:) ⇒ ActiveJob

Returns a new instance of ActiveJob.



10
11
12
13
14
 
# File 'lib/bulk_processor/back_end/active_job.rb', line 10

def initialize(processor_class:, payload:, key:)
  @processor_class = processor_class.name
  @payload = PayloadSerializer.serialize(payload)
  @key = key
end

Instance Method Details

#split(num_processes) ⇒ Object 



20
21
22
23
 
# File 'lib/bulk_processor/back_end/active_job.rb', line 20

def split(num_processes)
  ActiveJob::SplitCSVJob.perform_later(processor_class, payload, key,
                                       num_processes)
end

#start ⇒ Object 



16
17
18
 
# File 'lib/bulk_processor/back_end/active_job.rb', line 16

def start
  ActiveJob::ProcessCSVJob.perform_later(processor_class, payload, key)
end