Class: CI::Queue::Configuration

Inherits:
Object
  • Object
show all
Defined in:
lib/ci/queue/configuration.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(timeout: 30, build_id: nil, worker_id: nil, max_requeues: 0, requeue_tolerance: 0, namespace: nil, seed: nil, flaky_tests: [], statsd_endpoint: nil, max_consecutive_failures: nil, grind_count: nil, max_duration: nil, failure_file: nil, max_test_duration: nil, max_test_duration_percentile: 0.5, track_test_duration: false) ⇒ Configuration

Returns a new instance of Configuration.



29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/ci/queue/configuration.rb', line 29

def initialize(
  timeout: 30, build_id: nil, worker_id: nil, max_requeues: 0, requeue_tolerance: 0,
  namespace: nil, seed: nil, flaky_tests: [], statsd_endpoint: nil, max_consecutive_failures: nil,
  grind_count: nil, max_duration: nil, failure_file: nil, max_test_duration: nil,
  max_test_duration_percentile: 0.5, track_test_duration: false
)
  @circuit_breakers = [CircuitBreaker::Disabled]
  @build_id = build_id
  @failure_file = failure_file
  @flaky_tests = flaky_tests
  @grind_count = grind_count
  @max_requeues = max_requeues
  @namespace = namespace
  @requeue_tolerance = requeue_tolerance
  @seed = seed
  @statsd_endpoint = statsd_endpoint
  @timeout = timeout
  @worker_id = worker_id
  @max_test_duration = max_test_duration
  @max_test_duration_percentile = max_test_duration_percentile
  @track_test_duration = track_test_duration
  self.max_duration = max_duration
  self.max_consecutive_failures = max_consecutive_failures
end

Instance Attribute Details

#build_id ⇒ Object

Returns the value of attribute build_id.



5
6
7
 
# File 'lib/ci/queue/configuration.rb', line 5

def build_id
  @build_id
end

#circuit_breakers ⇒ Object (readonly)

Returns the value of attribute circuit_breakers.



8
9
10
 
# File 'lib/ci/queue/configuration.rb', line 8

def circuit_breakers
  @circuit_breakers
end

#failing_test ⇒ Object

Returns the value of attribute failing_test.



6
7
8
 
# File 'lib/ci/queue/configuration.rb', line 6

def failing_test
  @failing_test
end

#failure_file ⇒ Object

Returns the value of attribute failure_file.



5
6
7
 
# File 'lib/ci/queue/configuration.rb', line 5

def failure_file
  @failure_file
end

#grind_count ⇒ Object

Returns the value of attribute grind_count.



5
6
7
 
# File 'lib/ci/queue/configuration.rb', line 5

def grind_count
  @grind_count
end

#max_requeues ⇒ Object

Returns the value of attribute max_requeues.



5
6
7
 
# File 'lib/ci/queue/configuration.rb', line 5

def max_requeues
  @max_requeues
end

#max_test_duration ⇒ Object

Returns the value of attribute max_test_duration.



7
8
9
 
# File 'lib/ci/queue/configuration.rb', line 7

def max_test_duration
  @max_test_duration
end

#max_test_duration_percentile ⇒ Object

Returns the value of attribute max_test_duration_percentile.



7
8
9
 
# File 'lib/ci/queue/configuration.rb', line 7

def max_test_duration_percentile
  @max_test_duration_percentile
end

#namespace ⇒ Object

Returns the value of attribute namespace.



6
7
8
 
# File 'lib/ci/queue/configuration.rb', line 6

def namespace
  @namespace
end

#requeue_tolerance ⇒ Object

Returns the value of attribute requeue_tolerance.



6
7
8
 
# File 'lib/ci/queue/configuration.rb', line 6

def requeue_tolerance
  @requeue_tolerance
end

#seed ⇒ Object

Returns the value of attribute seed.



6
7
8
 
# File 'lib/ci/queue/configuration.rb', line 6

def seed
  @seed
end

#statsd_endpoint ⇒ Object

Returns the value of attribute statsd_endpoint.



6
7
8
 
# File 'lib/ci/queue/configuration.rb', line 6

def statsd_endpoint
  @statsd_endpoint
end

#timeout ⇒ Object

Returns the value of attribute timeout.



5
6
7
 
# File 'lib/ci/queue/configuration.rb', line 5

def timeout
  @timeout
end

#track_test_duration ⇒ Object

Returns the value of attribute track_test_duration.



7
8
9
 
# File 'lib/ci/queue/configuration.rb', line 7

def track_test_duration
  @track_test_duration
end

#worker_id ⇒ Object

Returns the value of attribute worker_id.



5
6
7
 
# File 'lib/ci/queue/configuration.rb', line 5

def worker_id
  @worker_id
end

Class Method Details

.from_env(env) ⇒ Object 



11
12
13
14
15
16
17
18
19
 
# File 'lib/ci/queue/configuration.rb', line 11

def from_env(env)
  new(
    build_id: env['CIRCLE_BUILD_URL'] || env['BUILDKITE_BUILD_ID'] || env['TRAVIS_BUILD_ID'] || env['HEROKU_TEST_RUN_ID'] || env['SEMAPHORE_PIPELINE_ID'],
    worker_id: env['CIRCLE_NODE_INDEX'] || env['BUILDKITE_PARALLEL_JOB'] || env['CI_NODE_INDEX'] || env['SEMAPHORE_JOB_ID'],
    seed: env['CIRCLE_SHA1'] || env['BUILDKITE_COMMIT'] || env['TRAVIS_COMMIT'] || env['HEROKU_TEST_RUN_COMMIT_VERSION'] || env['SEMAPHORE_GIT_SHA'],
    flaky_tests: load_flaky_tests(env['CI_QUEUE_FLAKY_TESTS']),
    statsd_endpoint: env['CI_QUEUE_STATSD_ADDR'],
  )
end

.load_flaky_tests(path) ⇒ Object 



21
22
23
24
25
26
 
# File 'lib/ci/queue/configuration.rb', line 21

def load_flaky_tests(path)
  return [] unless path
  ::File.readlines(path).map(&:chomp).to_set
rescue SystemCallError
  []
end

Instance Method Details

#flaky?(test) ⇒ Boolean

Returns:

  • (Boolean) 


66
67
68
 
# File 'lib/ci/queue/configuration.rb', line 66

def flaky?(test)
  @flaky_tests.include?(test.id)
end

#global_max_requeues(tests_count) ⇒ Object 



82
83
84
 
# File 'lib/ci/queue/configuration.rb', line 82

def global_max_requeues(tests_count)
  (tests_count * Float(requeue_tolerance)).ceil
end

#max_consecutive_failures=(max) ⇒ Object 



54
55
56
57
58
 
# File 'lib/ci/queue/configuration.rb', line 54

def max_consecutive_failures=(max)
  if max
    @circuit_breakers << CircuitBreaker.new(max_consecutive_failures: max)
  end
end

#max_duration=(duration) ⇒ Object 



60
61
62
63
64
 
# File 'lib/ci/queue/configuration.rb', line 60

def max_duration=(duration)
  if duration
    @circuit_breakers << CircuitBreaker::Timeout.new(duration: duration)
  end
end