Contents

require_relative './base_job'

module CanvasSync
  module JobBatches
    class ConcurrentBatchJob < BaseJob
      def perform(sub_jobs, context: nil)
        Batch.new.tap do |b|
          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

4 entries across 4 versions & 1 rubygems

Version	Path
canvas_sync-0.17.0.beta4	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.17.0.beta3	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.17.0.beta2	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb
canvas_sync-0.17.0.beta1	lib/canvas_sync/job_batches/jobs/concurrent_batch_job.rb