mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 19:56:01 +00:00
improve PDBs cleanup
This commit is contained in:
parent
158f6b78da
commit
5a0f1c8747
@ -1410,8 +1410,18 @@ func addKubeSystemPdbs(f *framework.Framework) (func(), error) {
|
|||||||
|
|
||||||
newPdbs := make([]string, 0)
|
newPdbs := make([]string, 0)
|
||||||
cleanup := func() {
|
cleanup := func() {
|
||||||
|
var finalErr error
|
||||||
for _, newPdbName := range newPdbs {
|
for _, newPdbName := range newPdbs {
|
||||||
f.ClientSet.Policy().PodDisruptionBudgets("kube-system").Delete(newPdbName, &metav1.DeleteOptions{})
|
By(fmt.Sprintf("Delete PodDisruptionBudget %v", newPdbName))
|
||||||
|
err := f.ClientSet.Policy().PodDisruptionBudgets("kube-system").Delete(newPdbName, &metav1.DeleteOptions{})
|
||||||
|
if err != nil {
|
||||||
|
// log error, but attempt to remove other pdbs
|
||||||
|
glog.Errorf("Failed to delete PodDisruptionBudget %v, err: %v", newPdbName, err)
|
||||||
|
finalErr = err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if finalErr != nil {
|
||||||
|
framework.Failf("Error during PodDisruptionBudget cleanup: %v", finalErr)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user