We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2c7fd3b commit d447fccCopy full SHA for d447fcc
lib/sidekiq-queue-pause.rb
@@ -52,7 +52,7 @@ def retrieve_work
52
if qcmd.size > 1
53
retrieve_work_for_queues qcmd
54
else
55
- sleep(Sidekiq::QueuePause.retry_after || Sidekiq::Fetcher::TIMEOUT)
+ sleep(Sidekiq::QueuePause.retry_after || Sidekiq::BasicFetch::TIMEOUT)
56
nil
57
end
58
@@ -65,7 +65,7 @@ def retrieve_work_for_queues(qcmd)
65
def unpaused_queues_cmd
66
queues = queues_cmd
67
queues.reject do |q|
68
- q != Sidekiq::Fetcher::TIMEOUT &&
+ q != Sidekiq::BasicFetch::TIMEOUT &&
69
Sidekiq::QueuePause.paused?(q.gsub('queue:', ''), Sidekiq::QueuePause.process_key)
70
71
0 commit comments