lib/ci/queue/redis/base.rb in ci-queue-0.12.1 vs lib/ci/queue/redis/base.rb in ci-queue-0.13.0

- old
+ new

@@ -1,19 +1,17 @@ module CI module Queue module Redis class Base + include Common + def initialize(redis_url, config) @redis_url = redis_url @redis = ::Redis.new(url: redis_url) @config = config end - def flaky?(test) - @config.flaky?(test) - end - def exhausted? queue_initialized? && size == 0 end def size @@ -57,10 +55,10 @@ end end private - attr_reader :redis, :config, :redis_url + attr_reader :redis, :redis_url def key(*args) ['build', build_id, *args].join(':') end