From 31945c57faffdb853dcd08cdde878ac7cb35b20c Mon Sep 17 00:00:00 2001 From: Tobias Persson Date: Wed, 29 Oct 2025 12:55:25 +0100 Subject: [PATCH] Ignore not found on delete --- internal/executionspace/executor/kubernetes.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/internal/executionspace/executor/kubernetes.go b/internal/executionspace/executor/kubernetes.go index a56d2b7..eadd33e 100644 --- a/internal/executionspace/executor/kubernetes.go +++ b/internal/executionspace/executor/kubernetes.go @@ -27,6 +27,7 @@ import ( corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/util/net" + apierrors "k8s.io/apimachinery/pkg/api/errors" watch "k8s.io/apimachinery/pkg/watch" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" @@ -190,8 +191,13 @@ func (k KubernetesExecutor) Stop(ctx context.Context, logger *logrus.Entry, name propagation := metav1.DeletePropagationForeground err := jobs.Delete(ctx, name, metav1.DeleteOptions{PropagationPolicy: &propagation}) if err != nil { - logger.Error(err.Error()) - return err + if apierrors.IsNotFound(err) { + logger.Warningf("Job %s not found, assuming already deleted", name) + return nil + } else { + logger.Error(err.Error()) + return err + } } watcher, err := k.client.CoreV1().Pods(k.namespace).Watch(ctx, metav1.ListOptions{LabelSelector: fmt.Sprintf("job-name=%s", name)}) if err != nil {