diff --git a/util/errors/errors.go b/util/errors/errors.go index 5eae7010461a..2982be216fd7 100644 --- a/util/errors/errors.go +++ b/util/errors/errors.go @@ -38,7 +38,7 @@ func IsTransientErr(err error) bool { isTransientEtcdErr(err) || matchTransientErrPattern(err) || errors.Is(err, NewErrTransient("")) || - strings.Contains(err.Error(), "upper: no more rows in ") + isTransientSqbErr(err) if isTransient { log.Infof("Transient error: %v", err) } else { @@ -124,3 +124,7 @@ func generateErrorString(err error) string { } return errorString } + +func isTransientSqbErr(err error) bool { + return strings.Contains(err.Error(), "upper: no more rows in") +}