1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
# frozen_string_literal: true
require 'parallel_tests'
require 'parallel_tests/rspec/logger_base'
class ParallelTests::RSpec::RuntimeLogger < ParallelTests::RSpec::LoggerBase
def initialize(*args)
super
@example_times = Hash.new(0)
@group_nesting = 0
end
RSpec::Core::Formatters.register(self, :example_group_started, :example_group_finished, :start_dump)
def example_group_started(example_group)
@time = ParallelTests.now if @group_nesting == 0
@group_nesting += 1
super
end
def example_group_finished(notification)
@group_nesting -= 1
if @group_nesting == 0
@example_times[notification.group.file_path] += ParallelTests.now - @time
end
super if defined?(super)
end
def seed(*); end
def dump_summary(*); end
def dump_failures(*); end
def dump_failure(*); end
def dump_pending(*); end
def start_dump(*)
return unless ENV['TEST_ENV_NUMBER'] # only record when running in parallel
lock_output do
# Order the output from slowest to fastest
@example_times = @example_times.sort_by(&:last).reverse
@example_times.each do |file, time|
relative_path = file.sub(%r{^#{Regexp.escape Dir.pwd}/}, '').sub(%r{^\./}, "")
@output.puts "#{relative_path}:#{[time, 0].max}"
end
end
@output.flush
end
end
|
