lib/ci/queue/redis/base.rb in ci-queue-0.13.3 vs lib/ci/queue/redis/base.rb in ci-queue-0.13.4
- old
+ new
@@ -2,9 +2,14 @@
module Queue
module Redis
class Base
include Common
+ CONNECTION_ERRORS = [
+ ::Redis::BaseConnectionError,
+ ::SocketError, # https://github.com/redis/redis-rb/pull/631
+ ].freeze
+
def initialize(redis_url, config)
@redis_url = redis_url
@redis = ::Redis.new(url: redis_url)
@config = config
end