Sha256: b7cf5bb7d91810893dfdba68ec2eed11e7f52824bf8e8a4fca1776d3bbaa7339
Contents?: true
Size: 512 Bytes
Versions: 30
Compression:
Stored size: 512 Bytes
Contents
require_relative './base_job'
module CanvasSync
module JobBatches
class ConcurrentBatchJob < BaseJob
def self.make_batch(sub_jobs, context: nil, &blk)
ManagedBatchJob.make_batch(
sub_jobs,
ordered: false,
concurrency: true,
context: context,
desc_prefix: 'ConcurrentBatchJob',
&blk
)
end
def perform(sub_jobs, context: nil)
self.class.make_batch(sub_jobs, context: context)
end
end
end
end
Version data entries
30 entries across 30 versions & 1 rubygems