Class: BulkProcessor::BackEnd::ActiveJob::SplitCSVTask

Inherits:
Object
  • Object
show all
Includes:
Rake::DSL
Defined in:
lib/bulk_processor/back_end/dynosaur/split_csv_task.rb

Instance Method Summary collapse

Instance Method Details

#install_task ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/bulk_processor/back_end/dynosaur/split_csv_task.rb', line 9

def install_task
  namespace :bulk_processor do
    desc 'Split a CSV file and process each piece'
    task :split, [:processor_class, :payload, :key, :num_chunks] => :environment do |_task, args|
      BulkProcessor::SplitCSV.new(
        args[:processor_class].constantize,
        PayloadSerializer.deserialize(args[:payload]),
        args[:key],
        args[:num_chunks].to_i
      ).perform
    end
  end
end