Sha256: d6b8472fe57d7c266fc8ad7bf9795284346c0a9d55f566c953a7cab53f1fb815
Contents?: true
Size: 412 Bytes
Versions: 22
Compression:
Stored size: 412 Bytes
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