lib/ci/queue/static.rb in ci-queue-0.16.0 vs lib/ci/queue/static.rb in ci-queue-0.17.0
- old
+ new
@@ -1,5 +1,7 @@
+# frozen_string_literal: true
+
module CI
module Queue
class Static
include Common
class << self
@@ -46,10 +48,10 @@
def size
@queue.size
end
def poll
- while !config.circuit_breaker.open? && test = @queue.shift
+ while !config.circuit_breakers.any?(&:open?) && test = @queue.shift
yield index.fetch(test)
end
end
def exhausted?