Contents

require_relative './base_job'

module CanvasSync::JobBatches
  class ConcurrentBatchJob < BaseJob
    def self.make_batch(sub_jobs, **kwargs, &blk)
      ManagedBatchJob.make_batch(
        sub_jobs,
        **kwargs,
        ordered: false,
        concurrency: true,
        desc_prefix: 'ConcurrentBatchJob: ',
        &blk
      )
    end

    def perform(sub_jobs, **kwargs)
      self.class.make_batch(sub_jobs, **kwargs)
    end
  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version	Path
canvas_sync-0.22.9	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.8	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.6	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.5	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.4	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.3	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.2	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.1	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0.beta8	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0.beta7	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0.beta6	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0.beta5	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0.beta4	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0.beta3	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0.beta2	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.22.0.beta1	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb