[deploy]Check if pod is creating

Author: Dev Agent

builder/deploy/deployer.go

@@ -434,6 +434,10 @@ func (d *deployer) Wakeup(ctx context.Context, dr types.DeployRequest) error {
 
 	// Spawn goroutine to handle HTTP request asynchronously
 	// This ensures the client.Timeout (20s) takes effect instead of the upstream context deadline
+	if len(cluster.AppEndpoint) < 1 {
+		// host is required for remote cluster with app endpoint
+		host = ""
+	}
 	go d.wakeUpDeploy(target, host, dr)
 
 	// Return immediately without waiting for the HTTP request to complete

common/types/repo.go

@@ -189,6 +189,7 @@ type InstanceInfo struct {
 	Message    string     `json:"message"`
 	Reason     string     `json:"reason"`
 	ReadyCount int        `json:"ready_count"`
+	IsCreating bool       `json:"is_creating"`
 }
 
 // repo object(cover model/space/code/dataset) for deployer

runner/component/service.go

@@ -365,6 +365,9 @@ func (s *serviceComponentImpl) getServicePodsWithStatus(ctx context.Context, clu
 				readyCount++
 			}
 		}
+		if !instanceInfo.IsCreating {
+			instanceInfo.IsCreating = isContainerCreating(&pod)
+		}
 	}
 	instanceInfo.Instances = podInstances
 	instanceInfo.ReadyCount = readyCount
@@ -929,7 +932,13 @@ func (s *serviceComponentImpl) getServiceStatus(ctx context.Context, ks v1.Servi
 	isActive, containerStatus := isUserContainerActive(instInfo.Instances)
 	switch {
 	case serviceCondition == nil, containerStatus == string(corev1.PodPending):
-		resp.Code = common.Pending
+		slog.DebugContext(ctx, "getServiceStatus for corev1.PodPending",
+			slog.Any("ksvc_name", ks.Name), slog.Any("instance info", instInfo))
+		if instInfo.IsCreating {
+			resp.Code = common.Deploying
+		} else {
+			resp.Code = common.Pending
+		}
 	case serviceCondition.Status == corev1.ConditionUnknown, serviceCondition.Status == corev1.ConditionFalse:
 		resp.Code = common.DeployFailed
 		if isActive && containerStatus == string(corev1.PodRunning) {