Sha256: 75e061d17e66b4fbb7c01f2333d9337002a552e0c0acf2322f0fed55b835512f
Contents?: true
Size: 650 Bytes
Versions: 33
Compression:
Stored size: 650 Bytes
Contents
require 'sidekiq/launcher'
require 'sidekiq/cli'
require 'sidekiq/api'
require 'sidekiq/processor'
require Dir.pwd + '/test/jobs/sidekiq_job_1.rb'
require Dir.pwd + '/test/jobs/sidekiq_job_2.rb'
::Instana.logger.info "Booting instrumented sidekiq worker for tests."
::Sidekiq.logger.level = ::Logger::FATAL
sidekiq_thread = Thread.new do
launcher = ::Sidekiq::Launcher.new(
::Sidekiq.options.merge(
queues: ['important'],
concurrency: 2
)
)
launcher.run
Thread.current[:worker] = launcher
end
Minitest.after_run do
::Instana.logger.info "Killing Sidekiq worker"
sidekiq_thread[:worker].stop
sleep 2
end
sleep 5
Version data entries
33 entries across 33 versions & 1 rubygems