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 0d3b539 commit 47df9b7Copy full SHA for 47df9b7
pkg/scheduler/cache/status_updater/concurrency_test.go
@@ -156,6 +156,15 @@ var _ = Describe("Status Updater Concurrency - large scale: increase queue size"
156
podGroupsFromCluster = append(podGroupsFromCluster, podGroup.DeepCopy())
157
}
158
159
+ Eventually(func() int {
160
+ numberOfPodGroupInFlight := 0
161
+ statusUpdater.inFlightPodGroups.Range(func(key any, value any) bool {
162
+ numberOfPodGroupInFlight += 1
163
+ return true
164
+ })
165
+ return numberOfPodGroupInFlight
166
+ }, time.Second*20, time.Millisecond*50).Should(Equal(0))
167
+
168
statusUpdater.SyncPodGroupsWithPendingUpdates(podGroupsFromCluster)
169
170
// check that the pods groups are now not updated anymore
0 commit comments