lib/ci/queue/static.rb in ci-queue-0.33.0 vs lib/ci/queue/static.rb in ci-queue-0.34.0

@@ -18,12 +18,17 @@
       def initialize(tests, config)
         @queue = tests
         @config = config
         @progress = 0
         @total = tests.size
+        @shutdown = false
       end
 
+      def shutdown!
+        @shutdown = true
+      end
+
       def distributed?
         false
       end
 
       def build
@@ -62,10 +67,10 @@
       def size
         @queue.size
       end
 
       def poll
-        while config.circuit_breakers.none?(&:open?) && !max_test_failed? && test = @queue.shift
+        while !@shutdown && config.circuit_breakers.none?(&:open?) && !max_test_failed? && test = @queue.shift
           yield index.fetch(test)
         end
       end
 
       def exhausted?