github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-02 08:17:26 +00:00
Code Issues Projects Releases Wiki Activity

using wait.Interrupted instead of deprecated wait.ErrWaitTimeout for utils

Browse Source
This commit is contained in:
wlq1212 2023-10-11 19:30:06 +08:00 committed by liqing.wu
parent 86a0b1c57a
commit d9545976ed
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/utils/deployment.go
View File

@ -105,7 +105,7 @@ func waitForDeploymentCompleteMaybeCheckRolling(c clientset.Interface, d *apps.D
return false, nil return false, nil
}) })
if err == wait.ErrWaitTimeout { if wait.Interrupted(err) {
err = fmt.Errorf("%s", reason) err = fmt.Errorf("%s", reason)
} }
if err != nil { if err != nil {
@ -224,7 +224,7 @@ func WaitForDeploymentRevisionAndImage(c clientset.Interface, ns, deploymentName
} }
return true, nil return true, nil
}) })
if err == wait.ErrWaitTimeout { if wait.Interrupted(err) {
LogReplicaSetsOfDeployment(deployment, nil, newRS, logf) LogReplicaSetsOfDeployment(deployment, nil, newRS, logf)
err = fmt.Errorf(reason) err = fmt.Errorf(reason)
} }
@ -316,7 +316,7 @@ func UpdateDeploymentWithRetries(c clientset.Interface, namespace, name string,
updateErr = err updateErr = err
return false, nil return false, nil
}) })
if pollErr == wait.ErrWaitTimeout { if wait.Interrupted(pollErr) {
pollErr = fmt.Errorf("couldn't apply the provided updated to deployment %q: %v", name, updateErr) pollErr = fmt.Errorf("couldn't apply the provided updated to deployment %q: %v", name, updateErr)
} }
return deployment, pollErr return deployment, pollErr
@ -375,7 +375,7 @@ func WaitForDeploymentWithCondition(c clientset.Interface, ns, deploymentName, r
cond := deploymentutil.GetDeploymentCondition(deployment.Status, condType) cond := deploymentutil.GetDeploymentCondition(deployment.Status, condType)
return cond != nil && cond.Reason == reason, nil return cond != nil && cond.Reason == reason, nil
}) })
if pollErr == wait.ErrWaitTimeout { if wait.Interrupted(pollErr) {
pollErr = fmt.Errorf("deployment %q never updated with the desired condition and reason, latest deployment conditions: %+v", deployment.Name, deployment.Status.Conditions) pollErr = fmt.Errorf("deployment %q never updated with the desired condition and reason, latest deployment conditions: %+v", deployment.Name, deployment.Status.Conditions)
_, allOldRSs, newRS, err := GetAllReplicaSets(deployment, c) _, allOldRSs, newRS, err := GetAllReplicaSets(deployment, c)
if err == nil { if err == nil {

4
test/utils/replicaset.go
View File

@ -47,7 +47,7 @@ func UpdateReplicaSetWithRetries(c clientset.Interface, namespace, name string,
updateErr = err updateErr = err
return false, nil return false, nil
}) })
if pollErr == wait.ErrWaitTimeout { if wait.Interrupted(pollErr) {
pollErr = fmt.Errorf("couldn't apply the provided updated to replicaset %q: %v", name, updateErr) pollErr = fmt.Errorf("couldn't apply the provided updated to replicaset %q: %v", name, updateErr)
} }
return rs, pollErr return rs, pollErr
@ -85,7 +85,7 @@ func UpdateReplicaSetStatusWithRetries(c clientset.Interface, namespace, name st
updateErr = err updateErr = err
return false, nil return false, nil
}) })
if pollErr == wait.ErrWaitTimeout { if wait.Interrupted(pollErr) {
pollErr = fmt.Errorf("couldn't apply the provided update to replicaset %q: %v", name, updateErr) pollErr = fmt.Errorf("couldn't apply the provided update to replicaset %q: %v", name, updateErr)
} }
return rs, pollErr return rs, pollErr