Sha256: 0e9ee73318334ab44b9ac6fcc6cc662e3e32208098b29e43836242daa92a4c69
Contents?: true
Size: 460 Bytes
Versions: 46
Compression:
Stored size: 460 Bytes
Contents
module Shipit
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
end
Version data entries
46 entries across 46 versions & 1 rubygems