lib/minitest/queue.rb in ci-queue-0.12.1 vs lib/minitest/queue.rb in ci-queue-0.13.0

@@ -141,10 +141,14 @@
     end
 
     def __run(*args)
       if queue
         run_from_queue(*args)
+
+        if queue.config.circuit_breaker.open?
+          STDERR.puts "This worker is exiting early because it encountered too many consecutive test failures, probably because of some corrupted state."
+        end
       else
         super
       end
     end
 
@@ -154,9 +158,15 @@
         failed = !(result.passed? || result.skipped?)
 
         if example.flaky?
           result.mark_as_flaked!
           failed = false
+        end
+
+        if failed
+          queue.report_failure!
+        else
+          queue.report_success!
         end
 
         if failed && queue.requeue(example)
           result.requeue!
           reporter.record(result)