Skip to content

Commit

Permalink
tiny change
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <[email protected]>
  • Loading branch information
rleungx committed Jan 2, 2025
1 parent 94f6f73 commit 1541b55
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions tests/integrations/mcs/scheduling/config_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -152,19 +152,19 @@ func (suite *configTestSuite) TestSchedulerConfigWatch() {
)
re.NoError(err)
// Get all default scheduler names.
var namesFromPDServer []string
var namesFromPDService []string
testutil.Eventually(re, func() bool {
namesFromPDServer, _, _ = suite.pdLeaderServer.GetRaftCluster().GetStorage().LoadAllSchedulerConfigs()
return len(namesFromPDServer) == len(sc.DefaultSchedulers)
namesFromPDService, _, _ = suite.pdLeaderServer.GetRaftCluster().GetStorage().LoadAllSchedulerConfigs()
return len(namesFromPDService) == len(sc.DefaultSchedulers)
})
// Check all default schedulers' configs.
var namesFromSchedulingServer []string
testutil.Eventually(re, func() bool {
namesFromSchedulingServer, _, err = storage.LoadAllSchedulerConfigs()
re.NoError(err)
return len(namesFromSchedulingServer) == len(namesFromPDServer)
return len(namesFromSchedulingServer) == len(namesFromPDService)
})
re.Equal(namesFromPDServer, namesFromSchedulingServer)
re.Equal(namesFromPDService, namesFromSchedulingServer)
// Add a new scheduler.
api.MustAddScheduler(re, suite.pdLeaderServer.GetAddr(), types.EvictLeaderScheduler.String(), map[string]any{
"store_id": 1,
Expand Down

0 comments on commit 1541b55

Please sign in to comment.