github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-19 07:25:19 +00:00
Code Issues Projects Releases Wiki Activity

test: wait for nodes to be in scheduler's cache

Browse Source
This commit is contained in:
saza-ku
2025-05-10 18:17:38 +09:00
parent e94babb2aa
commit 3911b677bd
1 changed files with 19 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
test/integration/scheduler/scoring/priorities_test.go
View File

@@ -296,11 +296,6 @@ func TestNodeResourcesScoring(t *testing.T) {
// works correctly.
func TestNodeAffinityScoring(t *testing.T) {
testCtx := initTestSchedulerForScoringTests(t, nodeaffinity.Name, nodeaffinity.Name)
// Add a few nodes.
_, err := createAndWaitForNodesInCache(testCtx, "testnode", st.MakeNode(), 4)
if err != nil {
t.Fatal(err)
}
// Add a label to one of the nodes.
labelKey := "kubernetes.io/node-topologyKey"
labelValue := "topologyvalue"
@@ -308,6 +303,11 @@ func TestNodeAffinityScoring(t *testing.T) {
if err != nil {
t.Fatalf("Cannot create labeled node: %v", err)
}
// Add a few nodes.
_, err = createAndWaitForNodesInCache(testCtx, "testnode", st.MakeNode(), 4)
if err != nil {
t.Fatal(err)
}
// Create a pod with node affinity.
podName := "pod-with-node-affinity"
@@ -744,6 +744,9 @@ func TestPodAffinityScoring(t *testing.T) {
t.Fatalf("failed to create node: %v", err)
}
}
if err := testutils.WaitForNodesInCache(testCtx.Ctx, testCtx.Scheduler, len(tt.nodes)); err != nil {
t.Fatalf("failed to wait for nodes in cache: %v", err)
}
for _, p := range tt.existingPods {
if _, err := runPausePod(testCtx.ClientSet, initPausePod(p)); err != nil {
@@ -838,6 +841,9 @@ func TestTaintTolerationScoring(t *testing.T) {
t.Fatalf("Failed to create node: %v", err)
}
}
if err := testutils.WaitForNodesInCache(testCtx.Ctx, testCtx.Scheduler, len(tt.nodes)); err != nil {
t.Fatalf("Failed to wait for nodes in cache: %v", err)
}
pod, err := runPausePod(testCtx.ClientSet, initPausePod(&testutils.PausePodConfig{
Name: fmt.Sprintf("test-pod-%v", i),
Namespace: testCtx.NS.Name,
@@ -1102,6 +1108,9 @@ func TestPodTopologySpreadScoring(t *testing.T) {
t.Fatalf("Cannot create node: %v", err)
}
}
if err := testutils.WaitForNodesInCache(testCtx.Ctx, testCtx.Scheduler, len(tt.nodes)); err != nil {
t.Fatalf("Failed to wait for nodes in cache: %v", err)
}
// set namespace to pods
for i := range tt.existingPods {
@@ -1149,9 +1158,10 @@ func TestDefaultPodTopologySpreadScoring(t *testing.T) {
testCtx := initTestSchedulerForScoringTests(t, podtopologyspread.Name, podtopologyspread.Name)
cs := testCtx.ClientSet
ns := testCtx.NS.Name
nodeNum := 300
zoneForNode := make(map[string]string)
for i := 0; i < 300; i++ {
for i := 0; i < nodeNum; i++ {
nodeName := fmt.Sprintf("node-%d", i)
zone := fmt.Sprintf("zone-%d", i%3)
zoneForNode[nodeName] = zone
@@ -1160,6 +1170,9 @@ func TestDefaultPodTopologySpreadScoring(t *testing.T) {
t.Fatalf("Cannot create node: %v", err)
}
}
if err := testutils.WaitForNodesInCache(testCtx.Ctx, testCtx.Scheduler, nodeNum); err != nil {
t.Fatalf("Failed to wait for nodes in cache: %v", err)
}
serviceName := "test-service"
svc := &v1.Service{