fix(ch): validatePeer increase timeout (#3545)

Author: heavycrystal

flow/cmd/validate_peer.go

@@ -14,8 +14,6 @@ func (h *FlowRequestHandler) ValidatePeer(
 	ctx context.Context,
 	req *protos.ValidatePeerRequest,
 ) (*protos.ValidatePeerResponse, APIError) {
-	ctx, cancelCtx := context.WithTimeout(ctx, 15*time.Second)
-	defer cancelCtx()
 	if req.Peer == nil {
 		return &protos.ValidatePeerResponse{
 			Status:  protos.ValidatePeerStatus_INVALID,
@@ -30,6 +28,15 @@ func (h *FlowRequestHandler) ValidatePeer(
 		}, NewInvalidArgumentApiError(errors.New("no peer name provided"))
 	}
 
+	validatePeerDeadline := 15 * time.Second
+	if req.Peer.Type == protos.DBType_CLICKHOUSE {
+		// if instance is overloaded, DDL can take longer than 15s to execute
+		validatePeerDeadline = 1 * time.Minute
+	}
+
+	ctx, cancelCtx := context.WithTimeout(ctx, validatePeerDeadline)
+	defer cancelCtx()
+
 	conn, err := connectors.GetConnector(ctx, nil, req.Peer)
 	if err != nil {
 		displayErr := fmt.Errorf("%s peer %s was invalidated: %w", req.Peer.Type, req.Peer.Name, err)