chore(Job): use WaitForCacheSync method after sharedInformerFactory Start

2025-09-08 04:32:37 +00:00 · 2024-07-19 23:41:20 +08:00
parent 01eb9f4754
commit af5b8bed70
1 changed files with 1 additions and 0 deletions
--- a/pkg/controller/job/job_controller_test.go
+++ b/pkg/controller/job/job_controller_test.go
@@ -6449,6 +6449,7 @@ func TestWatchJobs(t *testing.T) {
 	stopCh := make(chan struct{})
 	defer close(stopCh)
 	sharedInformerFactory.Start(stopCh)
+	sharedInformerFactory.WaitForCacheSync(stopCh)
 	go manager.Run(ctx, 1)

 	// We're sending new job to see if it reaches syncHandler.