upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-06-09 00:34:10 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix flaky TestSchedulerRestartWithNominatedNode

Browse source
This commit is contained in:
Bartosz 2026-05-05 11:11:40 +00:00
parent 47f9904374
commit c8a0c4bee3
No known key found for this signature in database
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
test/integration/scheduler/nominated_node_name/nominated_node_name_test.go
View file

@ -828,17 +828,23 @@ func TestSchedulerRestartWithNominatedNode(t *testing.T) {
pls = append(pls, mockQueueSort, mockPreBind)
pls = append(pls, additionalPlugins...)
registry, prof := schedulerutils.InitRegistryAndConfig(t, nil, pls...)
return schedulerutils.InitTestSchedulerForFrameworkTest(t, testContext, 0,
testCtx, teardown := schedulerutils.InitTestSchedulerForFrameworkTest(t, testContext, 0,
false, /* do not run scheduler immediately after init */
scheduler.WithProfiles(prof),
scheduler.WithFrameworkOutOfTreeRegistry(registry),
)
// Ensure both nodes are in the cache before proceeding
if err := testutils.WaitForNodesInCache(testCtx.Ctx, testCtx.Scheduler, 2); err != nil {
t.Fatalf("Failed to wait for nodes in cache: %v", err)
}
return testCtx, teardown
}
// To allow triggering scheduler restart in binding phase, we need to initialize the scheduler
// and pass the testCtx.SchedulerCloseFn to the bind plugin before calling Scheduler.Run.
mockBind := &mockBindPlugin{}
testCtx, _ := initSched(mockBind)
// This will fail the binding cycle and stop the scheduler
// Scheduler should set NNN for podA before this step.
mockBind.bindFn = func() *fwk.Status {