Fix TestUpdateWeight (#3942)

yycptt · web-flow · commit df9ec34239b0 · 2023-02-10T18:39:01.000-08:00
diff --git a/common/tasks/interleaved_weighted_round_robin_test.go b/common/tasks/interleaved_weighted_round_robin_test.go
@@ -86,7 +86,7 @@ func (s *interleavedWeightedRoundRobinSchedulerSuite) SetupTest() {
 		2: 2,
 		3: 1,
 	}
-	s.channelWeightUpdateCh = make(chan struct{})
+	s.channelWeightUpdateCh = make(chan struct{}, 1)
 	logger := log.NewTestLogger()
 
 	s.scheduler = NewInterleavedWeightedRoundRobinScheduler(

Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,7 @@ func (s *interleavedWeightedRoundRobinSchedulerSuite) SetupTest() {`
`86`	`86`	`2: 2,`
`87`	`87`	`3: 1,`
`88`	`88`	`}`
`89`		`- s.channelWeightUpdateCh = make(chan struct{})`
	`89`	`+ s.channelWeightUpdateCh = make(chan struct{}, 1)`
`90`	`90`	`logger := log.NewTestLogger()`
`91`	`91`
`92`	`92`	`s.scheduler = NewInterleavedWeightedRoundRobinScheduler(`