Sha256: 5436754d233c1da8488d40862e2a72a6801c3a341584fb807a72e9ff0653bad4
Contents?: true
Size: 912 Bytes
Versions: 108
Compression:
Stored size: 912 Bytes
Contents
require_relative '../integration_helper'
# Workflow when a Job fails, retries, and then succeeds
class Worker1
include Sidekiq::Worker
sidekiq_options retry: 5
@@failed = false
def perform
Sidekiq.logger.info "Work 1"
unless @@failed
@@failed = true
raise "One Failure"
end
end
end
class MyCallback
def on_success(status, options)
Sidekiq.logger.info "Overall Success #{options} #{status.data}"
end
alias_method :multi, :on_success
def on_complete(status, options)
Sidekiq.logger.info "Overall Complete #{options} #{status.data}"
end
end
overall = CanvasSync::JobBatches::Batch.new
overall.on(:success, MyCallback, to: 'success@gmail.com')
overall.on(:complete, MyCallback, to: 'success@gmail.com')
overall.jobs do
Worker1.perform_async
end
puts "Overall bid #{overall.bid}"
output, keys = process_tests
overall_tests(output, keys, file: __FILE__)
Version data entries
108 entries across 108 versions & 1 rubygems