class ParallelTests::Grouper
Public Class Methods
by_scenarios(tests, num_groups, options={})
click to toggle source
# File lib/parallel_tests/grouper.rb, line 9 def by_scenarios(tests, num_groups, options={}) scenarios = group_by_scenarios(tests, options) in_even_groups_by_size(scenarios, num_groups) end
by_steps(tests, num_groups, options)
click to toggle source
# File lib/parallel_tests/grouper.rb, line 4 def by_steps(tests, num_groups, options) features_with_steps = build_features_with_steps(tests, options) in_even_groups_by_size(features_with_steps, num_groups) end
in_even_groups_by_size(items, num_groups, options= {})
click to toggle source
# File lib/parallel_tests/grouper.rb, line 14 def in_even_groups_by_size(items, num_groups, options= {}) groups = Array.new(num_groups) { {:items => [], :size => 0} } # add all files that should run in a single process to one group (options[:single_process] || []).each do |pattern| matched, items = items.partition { |item, _size| item =~ pattern } matched.each { |item, size| add_to_group(groups.first, item, size) } end groups_to_fill = (options[:isolate] ? groups[1..-1] : groups) group_features_by_size(items_to_group(items), groups_to_fill) groups.map! { |g| g[:items].sort } end
Private Class Methods
add_to_group(group, item, size)
click to toggle source
# File lib/parallel_tests/grouper.rb, line 39 def add_to_group(group, item, size) group[:items] << item group[:size] += size end
build_features_with_steps(tests, options)
click to toggle source
# File lib/parallel_tests/grouper.rb, line 44 def build_features_with_steps(tests, options) require 'parallel_tests/gherkin/listener' listener = ParallelTests::Gherkin::Listener.new listener.ignore_tag_pattern = Regexp.compile(options[:ignore_tag_pattern]) if options[:ignore_tag_pattern] parser = ::Gherkin::Parser::Parser.new(listener, true, 'root') tests.each do |file| parser.parse(File.read(file), file, 0) end listener.collect.sort_by { |_, value| -value } end
group_by_scenarios(tests, options={})
click to toggle source
# File lib/parallel_tests/grouper.rb, line 55 def group_by_scenarios(tests, options={}) require 'parallel_tests/cucumber/scenarios' ParallelTests::Cucumber::Scenarios.all(tests, options) end
group_features_by_size(items, groups_to_fill)
click to toggle source
# File lib/parallel_tests/grouper.rb, line 60 def group_features_by_size(items, groups_to_fill) items.each do |item, size| size ||= 1 smallest = smallest_group(groups_to_fill) add_to_group(smallest, item, size) end end
items_to_group(items)
click to toggle source
# File lib/parallel_tests/grouper.rb, line 68 def items_to_group(items) items.first && items.first.size == 2 ? largest_first(items) : items end
largest_first(files)
click to toggle source
# File lib/parallel_tests/grouper.rb, line 31 def largest_first(files) files.sort_by{|_item, size| size }.reverse end
smallest_group(groups)
click to toggle source
# File lib/parallel_tests/grouper.rb, line 35 def smallest_group(groups) groups.min_by { |g| g[:size] } end