debug

Signed-off-by: Ryan Leung <[email protected]>
tikv · Dec 4, 2024 · c3f0411 · c3f0411
1 parent e0f0e97
commit c3f0411
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/tests/integrations/mcs/scheduling/server_test.go b/tests/integrations/mcs/scheduling/server_test.go
@@ -500,6 +500,9 @@ func (suite *serverTestSuite) TestStoreLimit() {
 	defer tc.Destroy()
 	leaderServer := suite.pdLeader.GetServer()
 	tc.WaitForPrimaryServing(re)
+	testutil.Eventually(re, func() bool {
+		return leaderServer.GetRaftCluster().IsServiceIndependent(constant.SchedulingServiceName)
+	})
 	oc := tc.GetPrimaryServer().GetCluster().GetCoordinator().GetOperatorController()
 
 	conf := leaderServer.GetReplicationConfig().Clone()

diff --git a/tests/scheduling_cluster.go b/tests/scheduling_cluster.go
@@ -107,7 +107,7 @@ func (tc *TestSchedulingCluster) WaitForPrimaryServing(re *require.Assertions) *
 	var primary *scheduling.Server
 	testutil.Eventually(re, func() bool {
 		for _, server := range tc.servers {
-			if server.IsServing() {
+			if server.IsServing() && server.GetCoordinator().AreSchedulersInitialized() {
 				primary = server
 				return true
 			}