diff --git a/util/errors/errors.go b/util/errors/errors.go index 72ba55aac774..b2dd3c0ebbf4 100644 --- a/util/errors/errors.go +++ b/util/errors/errors.go @@ -47,6 +47,7 @@ func isTransientErr(err error) bool { isResourceQuotaTimeoutErr(err) || isTransientNetworkErr(err) || apierr.IsServerTimeout(err) || + apierr.IsInternalError(err) || apierr.IsTimeout(err) || apierr.IsServiceUnavailable(err) || isTransientEtcdErr(err) || diff --git a/util/errors/errors_test.go b/util/errors/errors_test.go index 5654ff668ab2..b2844137cbb2 100644 --- a/util/errors/errors_test.go +++ b/util/errors/errors_test.go @@ -69,8 +69,9 @@ func TestIsTransientErr(t *testing.T) { assert.Contains(t, hook.LastEntry().Msg, "Transient error") }) t.Run("ResourceQuotaTimeoutErr", func(t *testing.T) { - assert.False(t, IsTransientErr(ctx, apierr.NewInternalError(errors.New("")))) + assert.True(t, IsTransientErr(ctx, apierr.NewInternalError(errors.New("")))) assert.True(t, IsTransientErr(ctx, apierr.NewInternalError(errors.New("resource quota evaluation timed out")))) + assert.True(t, IsTransientErr(ctx, apierr.NewInternalError(errors.New("some other transient 500")))) }) t.Run("ExceededQuotaErr", func(t *testing.T) { assert.False(t, IsTransientErr(ctx, apierr.NewForbidden(schema.GroupResource{}, "", nil)))