handle case where all queues are paused, fixes #4825

sidekiq · Feb 23, 2021 · ed84837 · ed84837
1 parent 285d654
commit ed84837
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/lib/sidekiq/fetch.rb b/lib/sidekiq/fetch.rb
@@ -36,7 +36,15 @@ def initialize(options)
     end
 
     def retrieve_work
-      work = Sidekiq.redis { |conn| conn.brpop(*queues_cmd) }
+      qs = queues_cmd
+      # 4825 Sidekiq Pro with all queues paused will return an
+      # empty set of queues with a trailing TIMEOUT value.
+      if qs.size <= 1
+        sleep(2)
+        return nil
+      end
+
+      work = Sidekiq.redis { |conn| conn.brpop(*qs) }
       UnitOfWork.new(*work) if work
     end