Module: RocketJob::Batch::LowerPriority

Extended by:

ActiveSupport::Concern

Defined in:

lib/rocket_job/batch/lower_priority.rb

Overview

Automatically lower the priority for Jobs with a higher record_count.

Note:

- Add `:lower_priority` as a before_batch, but only once the `record_count` has been set.
- If the `record_count` is not set by the time this plugins `before_batch`
  is called, then the priority will not be modified.

class SampleJob < RocketJob::Job

include RocketJob::Plugins::Batch
include RocketJob::Plugins::Batch::LowerPriority

before_batch :upload_data, :lower_priority

def perform(record)
  record.reverse
end

private

def upload_data
  upload do |stream|
    stream << 'abc'
    stream << 'def'
    stream << 'ghi'
  end
end

end