fix(k8s): correct delete of job when not found

caos · Nov 5, 2021 · c3d718c · c3d718c
1 parent 5eb4d03
commit c3d718c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kubernetes/client.go b/pkg/kubernetes/client.go
@@ -493,7 +493,7 @@ func (c *Client) DeleteJob(namespace string, name string) error {
 		return err
 	}
 
-	if job != nil {
+	if job != nil && err == nil && job.Spec.Selector != nil && job.Spec.Selector.MatchLabels != nil {
 		//Pod cleanup if necessary
 		return notFoundIsSuccess(c.DeletePodsByLabels(namespace, job.Spec.Selector.MatchLabels))
 	}