From 5ff184ba1d15cd1121ccabba4fde3da1c83cd42f Mon Sep 17 00:00:00 2001 From: moelsayed Date: Mon, 1 Jul 2019 23:42:34 +0200 Subject: [PATCH] Don't error out on pod delete IfNotFound --- k8s/pod.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 } }