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