From 2802fb2aecd52a5923b473857bf1804df5b1e3e0 Mon Sep 17 00:00:00 2001
From: Rintaro Okamura <rintaro.okamura@gmail.com>
Date: Mon, 24 May 2021 07:04:54 +0000
Subject: [PATCH] :fire: Remove invalid initialization option

---
 internal/db/kvs/redis/redis.go | 7 -------
 1 file changed, 7 deletions(-)

diff --git a/internal/db/kvs/redis/redis.go b/internal/db/kvs/redis/redis.go
index 85dc8c79d9..eabd97e850 100644
--- a/internal/db/kvs/redis/redis.go
+++ b/internal/db/kvs/redis/redis.go
@@ -230,13 +230,6 @@ func (rc *redisClient) newClusterClient(ctx context.Context) (c *redis.ClusterCl
 	} else {
 		c = redis.NewClusterClient(&redis.ClusterOptions{
 			Addrs: rc.addrs,
-			NewClient: func(opt *redis.Options) *redis.Client {
-				c, err := rc.newClient(ctx)
-				if err != nil {
-					return redis.NewClient(opt)
-				}
-				return c
-			},
 			Dialer:             rc.dialerFunc,
 			MaxRedirects:       rc.maxRedirects,
 			ReadOnly:           rc.readOnly,