Module: Minitest::Queue

Extended by:
CI::Queue::OutputHelpers
Defined in:
lib/minitest/queue.rb,
lib/minitest/queue/runner.rb,
lib/minitest/queue/statsd.rb,
lib/minitest/queue/test_data.rb,
lib/minitest/queue/error_report.rb,
lib/minitest/queue/grind_recorder.rb,
lib/minitest/queue/grind_reporter.rb,
lib/minitest/queue/junit_reporter.rb,
lib/minitest/queue/failure_formatter.rb,
lib/minitest/queue/test_data_reporter.rb,
lib/minitest/queue/test_time_recorder.rb,
lib/minitest/queue/test_time_reporter.rb,
lib/minitest/queue/lazy_entry_resolver.rb,
lib/minitest/queue/lazy_test_discovery.rb,
lib/minitest/queue/build_status_recorder.rb,
lib/minitest/queue/build_status_reporter.rb,
lib/minitest/queue/local_requeue_reporter.rb,
lib/minitest/queue/worker_profile_reporter.rb,
lib/minitest/queue/queue_population_strategy.rb

Defined Under Namespace

Classes: BuildStatusRecorder, BuildStatusReporter, ErrorReport, FailureFormatter, GrindRecorder, GrindReporter, JUnitReporter, LazyEntryResolver, LazySingleExample, LazyTestDiscovery, LocalRequeueReporter, OrderReporter, QueuePopulationStrategy, Runner, SingleExample, Statsd, TestData, TestDataReporter, TestTimeRecorder, TestTimeReporter, WorkerProfileReporter

Constant Summary collapse

DEFAULT_RUN_COMMAND_FORMATTER = 
lambda do |runnable|
  filename = Minitest::Queue.relative_path(runnable.source_location[0])
  identifier = "#{runnable.klass}##{runnable.name}"
  ['bundle', 'exec', 'ruby', '-Ilib:test', filename, '-n', identifier]
end
RAILS_RUN_COMMAND_FORMATTER = 
lambda do |runnable|
  filename = Minitest::Queue.relative_path(runnable.source_location[0])
  lineno = runnable.source_location[1]
  ['bin/rails', 'test', "#{filename}:#{lineno}"]
end

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#project_root=(value) ⇒ Object (writeonly)

Sets the attribute project_root

Parameters:

  • value —

    the value to set the attribute project_root to.



116
117
118
 
# File 'lib/minitest/queue.rb', line 116

def project_root=(value)
  @project_root = value
end

#queue ⇒ Object

Returns the value of attribute queue.



536
537
538
 
# File 'lib/minitest/queue.rb', line 536

def queue
  @queue
end

#run_command_formatter ⇒ Object 



118
119
120
121
122
123
124
 
# File 'lib/minitest/queue.rb', line 118

def run_command_formatter
  @run_command_formatter ||= if defined?(Rails) && defined?(Rails::TestUnitRailtie)
    RAILS_RUN_COMMAND_FORMATTER
  else
    DEFAULT_RUN_COMMAND_FORMATTER
  end
end

Class Method Details

.handle_test_result(reporter, example, result) ⇒ Object 



181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
 
# File 'lib/minitest/queue.rb', line 181

def handle_test_result(reporter, example, result)
  if result.respond_to?(:queue_id=)
    result.queue_id = example.id
    result.queue_entry = example.queue_entry if result.respond_to?(:queue_entry=)
  end

  failed = !(result.passed? || result.skipped?)

  if example.flaky?
    result.mark_as_flaked!
    failed = false
  end

  if failed && queue.config.failing_test && queue.config.failing_test != example.id
    # When we do a bisect, we don't care about the result other than the test we're running the bisect on
    result.mark_as_flaked!
    failed = false
  elsif failed
    queue.report_failure!
  else
    queue.report_success!
  end

  if failed && CI::Queue.requeueable?(result) && queue.requeue(example)
    result.requeue!
  end
  reporter.record(result)
end

.project_root ⇒ Object 



147
148
149
 
# File 'lib/minitest/queue.rb', line 147

def self.project_root
  @project_root ||= Dir.pwd
end

.queue ⇒ Object 



158
159
160
 
# File 'lib/minitest/queue.rb', line 158

def queue
  Minitest.queue
end

.relative_path(path, root: project_root) ⇒ Object 



151
152
153
154
155
 
# File 'lib/minitest/queue.rb', line 151

def self.relative_path(path, root: project_root)
  Pathname(path).relative_path_from(Pathname(root)).to_s
rescue ArgumentError, TypeError
  path
end

.run(reporter) ⇒ Object 



162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
 
# File 'lib/minitest/queue.rb', line 162

def run(reporter, *)
  rescue_run_errors do
    begin
      queue.poll do |example|
        result = queue.with_heartbeat(example.queue_entry) do
          example.run
        end

        handle_test_result(reporter, example, result)
      end

      report_load_stats(queue)
    ensure
      store_worker_profile(queue)
      queue.stop_heartbeat!
    end
  end
end

Instance Method Details

#__run(*args) ⇒ Object 



553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
 
# File 'lib/minitest/queue.rb', line 553

def __run(*args)
  if queue
    Queue.run(*args)

    if queue.config.circuit_breakers.any?(&:open?)
      STDERR.puts queue.config.circuit_breakers.map(&:message).join(' ').strip
    end

    if queue.max_test_failed?
      STDERR.puts 'This worker is exiting early because too many failed tests were encountered.'
    end
  else
    super
  end
end

#loaded_tests ⇒ Object 



545
546
547
548
549
550
551
 
# File 'lib/minitest/queue.rb', line 545

def loaded_tests
  Minitest::Test.runnables.flat_map do |runnable|
    runnable.runnable_methods.map do |method_name|
      SingleExample.new(runnable, method_name)
    end
  end
end

#queue_reporters=(reporters) ⇒ Object 



538
539
540
541
542
543
 
# File 'lib/minitest/queue.rb', line 538

def queue_reporters=(reporters)
  @queue_reporters ||= []
  Reporters.use!(((Reporters.reporters || []) - @queue_reporters) + reporters)
  Minitest.backtrace_filter.add_filter(%r{exe/minitest-queue|lib/ci/queue/})
  @queue_reporters = reporters
end

#run_command_for_runnable(runnable) ⇒ Object 



138
139
140
141
142
143
144
145
 
# File 'lib/minitest/queue.rb', line 138

def run_command_for_runnable(runnable)
  command = run_command_formatter.call(runnable)
  if command.is_a?(Array)
    Shellwords.join(command)
  else
    command
  end
end