Add node cache sync wait in TestPodController tests (kubernetes-sigs#1435)

* test: add node cache sync wait in TestPodController

* re-run failed job

Author: anson627

pkg/kwok/controllers/node_controller_test.go

@@ -100,6 +100,7 @@ func TestNodeController(t *testing.T) {
 	nodeCh := make(chan informer.Event[*corev1.Node], 1)
 	nodesCli := clientset.CoreV1().Nodes()
 	nodesInformer := informer.NewInformer[*corev1.Node, *corev1.NodeList](nodesCli)
+
 	err = nodesInformer.Watch(ctx, informer.Option{
 		AnnotationSelector: "node=true",
 	}, nodeCh)

pkg/kwok/controllers/pod_controller_test.go

@@ -191,6 +191,22 @@ func TestPodController(t *testing.T) {
 		t.Fatal(fmt.Errorf("failed to watch nodes: %w", err))
 	}
 
+	// Wait for node cache to sync
+	err = wait.Poll(ctx, func(ctx context.Context) (done bool, err error) {
+		_, ok := nodeCache.Get("node0")
+		if !ok {
+			return false, nil
+		}
+		_, ok = nodeCache.Get("node1")
+		if !ok {
+			return false, nil
+		}
+		return true, nil
+	}, wait.WithContinueOnError(5))
+	if err != nil {
+		t.Fatal(fmt.Errorf("failed to wait for node cache sync: %w", err))
+	}
+
 	lc, _ := lifecycle.NewLifecycle(podStages)
 	annotationSelector, _ := labels.Parse("fake=custom")
 	pods, err := NewPodController(PodControllerConfig{