Class: RSpec::Queue::Runner

Inherits:

Core::Runner

• Object
• Core::Runner
• RSpec::Queue::Runner

Includes:

CI::Queue::OutputHelpers, RunnerHelpers

Defined in:

lib/rspec/queue.rb

Instance Method Summary

• #run_specs(example_groups) ⇒ Object
• #setup(err, out) ⇒ Object

Instance Method Details

#run_specs(example_groups) ⇒ Object

# File 'lib/rspec/queue.rb', line 370

def run_specs(example_groups)
  examples = example_groups.flat_map(&:descendants).flat_map do |example_group|
    example_group.filtered_examples.map do |example|
      SingleExample.new(example_group, example)
    end
  end

  queue = CI::Queue.from_uri(queue_url, RSpec::Queue.config)
  queue = queue.retry_queue if retrying
  BuildStatusRecorder.build = queue.build
  queue.populate(examples, random: ordering_seed, &:id)
  examples_count = examples.size # TODO: figure out which stub value would be best
  success = true
  @configuration.reporter.report(examples_count) do |reporter|
    @configuration.add_formatter(BuildStatusRecorder)

    @configuration.with_suite_hooks do
      break if @world.wants_to_quit
      queue.poll do |example|
        success &= example.run(QueueReporter.new(reporter, queue, example))
        break if @world.wants_to_quit
      end
    end
  end

  return 0 if @world.non_example_failure
  success ? 0 : @configuration.failure_exit_code
end

#setup(err, out) ⇒ Object

# File 'lib/rspec/queue.rb', line 362

def setup(err, out)
  super
  invalid_usage!('Missing --queue parameter') unless queue_url
  invalid_usage!('Missing --build parameter') unless RSpec::Queue.config.build_id
  invalid_usage!('Missing --worker parameter') unless RSpec::Queue.config.worker_id
  RSpec.configuration.backtrace_formatter.filter_gem('ci-queue')
end