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