Sha256: c16774add4617144449708a8228a50522d2415d4f912c1838cf0dc10a4ea3d6e
Contents?: true
Size: 887 Bytes
Versions: 126
Compression:
Stored size: 887 Bytes
Contents
require 'integration_helper'
# Simple nested batch without callbacks
# Batches:
# - Overall (Worker1)
# - Worker2
class Worker1
include Sidekiq::Worker
def perform
Sidekiq.logger.info "Work1"
batch = CanvasSync::JobBatches::Batch.new
batch.jobs do
Worker2.perform_async
end
end
end
class Worker2
include Sidekiq::Worker
def perform
Sidekiq.logger.info "Work2"
end
end
class SomeClass
def on_complete(status, options)
Sidekiq.logger.info "Overall Complete #{options} #{status.data}"
end
def on_success(status, options)
Sidekiq.logger.info "Overall Success #{options} #{status.data}"
end
end
batch = CanvasSync::JobBatches::Batch.new
batch.on(:success, SomeClass)
batch.on(:complete, SomeClass)
batch.jobs do
Worker1.perform_async
end
puts "Overall bid #{batch.bid}"
output, keys = process_tests
overall_tests output, keys
Version data entries
126 entries across 126 versions & 1 rubygems