diff --git a/k8s/pod.go b/k8s/pod.go index 14bb079f..ffa2709b 100644 --- a/k8s/pod.go +++ b/k8s/pod.go @@ -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 } }