Skip to content

Commit

Permalink
Support Sidekiq 7.0+
Browse files Browse the repository at this point in the history
  • Loading branch information
y-yagi committed Jan 14, 2024
1 parent 8487679 commit d34b063
Showing 1 changed file with 22 additions and 7 deletions.
29 changes: 22 additions & 7 deletions test/support/sidekiq/test_helper.rb
Original file line number Diff line number Diff line change
Expand Up @@ -7,13 +7,28 @@
end

def execute_with_launcher
sidekiq = Sidekiq::Launcher.new({queues: [FailJob.queue_name.call],
environment: "test",
concurrency: 1,
timeout: 1,
})
Sidekiq.average_scheduled_poll_interval = 3
Sidekiq.options[:poll_interval_average] = 1
if Gem::Version.new(Sidekiq::VERSION) >= Gem::Version.new("7")
config = Sidekiq.default_configuration
config.queues = [FailJob.queue_name.call]
config.concurrency = 1
config.average_scheduled_poll_interval = 0.5
config.merge!(
environment: "test",
timeout: 1,
poll_interval_average: 3
)
else
config = {
queues: [FailJob.queue_name.call],
environment: "test",
concurrency: 1,
timeout: 1,
average_scheduled_poll_interval: 0.5,
poll_interval_average: 3
}
end

sidekiq = Sidekiq::Launcher.new(config)
sidekiq.run
yield
sidekiq.stop
Expand Down

0 comments on commit d34b063

Please sign in to comment.