Sha256: c87cf269ee55d0fae12d0c1e3b6370fa4d8a727045ea8768dceb30ae20d9ad2f
Contents?: true
Size: 424 Bytes
Versions: 51
Compression:
Stored size: 424 Bytes
Contents
require_relative './base_job'
module CanvasSync
module JobBatches
class ConcurrentBatchJob < BaseJob
def perform(sub_jobs, context: nil)
Batch.new.tap do |b|
b.description = "Concurrent Batch Root"
b.context = context
b.jobs do
sub_jobs.each do |j|
ChainBuilder.enqueue_job(j)
end
end
end
end
end
end
end
Version data entries
51 entries across 51 versions & 1 rubygems