1
0
mirror of https://github.com/rancher/rke.git synced 2025-08-25 09:58:34 +00:00

Don't error out on pod delete IfNotFound

This commit is contained in:
moelsayed 2019-07-01 23:42:34 +02:00 committed by Alena Prokharchyk
parent 42c097275a
commit 5ff184ba1d

View File

@ -1,14 +1,15 @@
package k8s
import (
"k8s.io/api/core/v1"
v1 "k8s.io/api/core/v1"
apierrors "k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
)
func DeletePods(k8sClient *kubernetes.Clientset, podList *v1.PodList) error {
for _, pod := range podList.Items {
if err := k8sClient.CoreV1().Pods(pod.Namespace).Delete(pod.Name, &metav1.DeleteOptions{}); err != nil {
if err := k8sClient.CoreV1().Pods(pod.Namespace).Delete(pod.Name, &metav1.DeleteOptions{}); err != nil && !apierrors.IsNotFound(err) {
return err
}
}