Module: Megatest::ShardeableQueue

Included in:
Queue
Defined in:
lib/megatest/queue.rb

Instance Method Summary collapse

Instance Method Details

#populate(test_cases) ⇒ Object 



80
81
82
83
84
85
86
 
# File 'lib/megatest/queue.rb', line 80

def populate(test_cases)
  if sharded?
    test_cases = test_cases.select.with_index { |_t, index| (index % @config.workers_count) == @config.worker_id }
  end

  super
end

#sharded? ⇒ Boolean

Returns:

  • (Boolean) 


76
77
78
 
# File 'lib/megatest/queue.rb', line 76

def sharded?
  @config.workers_count > 1
end