Contents

class ChunkRollupJob < BackgroundJob
  include BackgroundJob::Unique

  queue_as :default

  def perform(task)
    unless task.finished?
      logger.error("Task ##{task.id} is not finished (current state: #{task.status}). Aborting.")
      return
    end

    if task.rolled_up?
      logger.error("Task ##{task.id} has already been rolled up. Aborting.")
      return
    end

    task.rollup_chunks
  end
end

Version data entries

22 entries across 22 versions & 1 rubygems

Version	Path
shipit-engine-0.1.0	app/jobs/chunk_rollup_job.rb
shipit-engine-0.0.1.pre	app/jobs/chunk_rollup_job.rb