From 008b92e0f6b749d07ab734a524720e8550f69fa5 Mon Sep 17 00:00:00 2001 From: Michael Aspinwall Date: Wed, 25 Feb 2026 17:13:50 +0000 Subject: [PATCH] Fix clearing job consistency store for all deletes --- pkg/controller/job/job_controller.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/pkg/controller/job/job_controller.go b/pkg/controller/job/job_controller.go index 5e90c84b4f4..5114fcd1106 100644 --- a/pkg/controller/job/job_controller.go +++ b/pkg/controller/job/job_controller.go @@ -601,6 +601,10 @@ func (jm *Controller) deleteJob(logger klog.Logger, obj interface{}) { return } } + jm.consistencyStore.Clear(types.NamespacedName{ + Namespace: jobObj.Namespace, + Name: jobObj.Name, + }, jobObj.UID) jm.finishedJobExpectations.Delete(jobObj.UID) jm.enqueueLabelSelector(jobObj) @@ -929,6 +933,10 @@ func (jm *Controller) syncJob(ctx context.Context, key string) (rErr error) { // re-syncing here as the record has to be removed for finished/deleted jobs return fmt.Errorf("error removing backoff record %w", err) } + jm.consistencyStore.Clear(types.NamespacedName{ + Namespace: job.Namespace, + Name: job.Name, + }, job.UID) jm.finishedJobExpectations.Delete(job.UID) return nil }