Merge pull request #104124 from aojea/flakelb

retry apiserver errors on e2e service tests
This commit is contained in:
Kubernetes Prow Robot 2021-08-05 16:36:54 -07:00 committed by GitHub
commit 05ee896667
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -603,7 +603,8 @@ func (j *TestJig) waitForCondition(timeout time.Duration, message string, condit
pollFunc := func() (bool, error) {
svc, err := j.Client.CoreV1().Services(j.Namespace).Get(context.TODO(), j.Name, metav1.GetOptions{})
if err != nil {
return false, err
framework.Logf("Retrying .... error trying to get Service %s: %v", j.Name, err)
return false, nil
}
if conditionFn(svc) {
service = svc
@ -612,7 +613,7 @@ func (j *TestJig) waitForCondition(timeout time.Duration, message string, condit
return false, nil
}
if err := wait.PollImmediate(framework.Poll, timeout, pollFunc); err != nil {
return nil, fmt.Errorf("timed out waiting for service %q to %s", j.Name, message)
return nil, fmt.Errorf("timed out waiting for service %q to %s: %w", j.Name, message, err)
}
return service, nil
}