fix: status updater deleted pod group race (#421)

enoodle · web-flow · commit f826ef3a4caa · 2025-08-21T16:00:36.000+02:00
diff --git a/pkg/scheduler/cache/status_updater/concurrency.go b/pkg/scheduler/cache/status_updater/concurrency.go
@@ -102,7 +102,10 @@ func (su *defaultStatusUpdater) updatePodGroup(
 	} else {
 		// Move the update to the applied cache
 		su.appliedPodGroupUpdates.Store(key, updateData)
-		su.inFlightPodGroups.Delete(key)
+		_, loaded := su.inFlightPodGroups.LoadAndDelete(key)
+		if !loaded {
+			su.appliedPodGroupUpdates.Delete(key)
+		}
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,10 @@ func (su *defaultStatusUpdater) updatePodGroup(`
`102`	`102`	`} else {`
`103`	`103`	`// Move the update to the applied cache`
`104`	`104`	`su.appliedPodGroupUpdates.Store(key, updateData)`
`105`		`- su.inFlightPodGroups.Delete(key)`
	`105`	`+ _, loaded := su.inFlightPodGroups.LoadAndDelete(key)`
	`106`	`+ if !loaded {`
	`107`	`+ su.appliedPodGroupUpdates.Delete(key)`
	`108`	`+ }`
`106`	`109`	`}`
`107`	`110`	`}`
`108`	`111`