Class: CI::Queue::Redis::Retry

Inherits:
Static
  • Object
show all
Defined in:
lib/ci/queue/redis/retry.rb

Instance Attribute Summary

Attributes inherited from Static

#progress, #total

Instance Method Summary collapse

Methods inherited from Static

#acknowledge, #exhausted?, from_uri, #poll, #populate, #populated?, #requeue, #retry_queue, #size, #supervisor, #to_a

Constructor Details

#initialize(tests, config, redis:) ⇒ Retry

Returns a new instance of Retry.



5
6
7
8
 
# File 'lib/ci/queue/redis/retry.rb', line 5

def initialize(tests, config, redis:)
  @redis = redis
  super(tests, config)
end

Instance Method Details

#minitest_reporters ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/ci/queue/redis/retry.rb', line 10

def minitest_reporters
  require 'minitest/reporters/queue_reporter'
  require 'minitest/reporters/redis_reporter'
  @minitest_reporters ||= [
    Minitest::Reporters::QueueReporter.new,
    Minitest::Reporters::RedisReporter::Worker.new(
      redis: redis,
      build_id: config.build_id,
      worker_id: config.worker_id,
    )
  ]
end