optimize: check worker status instead of exit quickly

pingcap · Dec 1, 2021 · 1a4a20e · 1a4a20e
1 parent 30d77ea
commit 1a4a20e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/dm/dm/master/server.go b/dm/dm/master/server.go
@@ -1681,6 +1681,10 @@ func (s *Server) waitOperationOk(
 					}
 				}
 			case *pb.StartTaskRequest, *pb.UpdateTaskRequest, *pb.OperateTaskRequest:
+				fmt.Printf("query response: %+v\n", queryResp.Result)
+				if expect == pb.Stage_Stopped && !queryResp.Result {
+					continue
+				}
 				if expect == pb.Stage_Stopped && len(queryResp.SubTaskStatus) == 0 {
 					return true, "", queryResp, nil
 				}