diff --git a/error.go b/error.go index d29c0c9..9fe1376 100644 --- a/error.go +++ b/error.go @@ -52,6 +52,9 @@ func shouldRetry(err error, retryTimeout bool) bool { if strings.HasPrefix(s, "CLUSTERDOWN ") { return true } + if strings.HasPrefix(s, "TRYAGAIN ") { + return true + } return false }