We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 294fa10 commit 990c403Copy full SHA for 990c403
pkg/upgrade/handle_batch.go
@@ -95,6 +95,7 @@ func (ctl *Controller) handleJobs(ctx context.Context) error {
95
}
96
return obj, enqueueOrDelete(jobs, obj, upgradejob.ConditionComplete)
97
98
+ // if the job is hasn't failed or completed but the job Node is not on the applying list, consider it running out-of-turn and delete it
99
if i := sort.SearchStrings(plan.Status.Applying, nodeName); i == len(plan.Status.Applying) ||
100
(i < len(plan.Status.Applying) && plan.Status.Applying[i] != nodeName) {
101
return obj, deleteJob(jobs, obj, metav1.DeletePropagationBackground)
0 commit comments