Browse Source

bug fix

pull/340/head
zhangwei 1 year ago
parent
commit
c5e6d67d06
2 changed files with 10 additions and 0 deletions
  1. +9
    -0
      internal/logic/core/taskdetailslogic.go
  2. +1
    -0
      internal/types/types.go

+ 9
- 0
internal/logic/core/taskdetailslogic.go View File

@@ -8,6 +8,7 @@ import (
"gitlink.org.cn/JointCloud/pcm-coordinator/pkg/models" "gitlink.org.cn/JointCloud/pcm-coordinator/pkg/models"
"gitlink.org.cn/JointCloud/pcm-coordinator/pkg/utils" "gitlink.org.cn/JointCloud/pcm-coordinator/pkg/utils"
"gorm.io/gorm" "gorm.io/gorm"
"strings"


"github.com/zeromicro/go-zero/core/logx" "github.com/zeromicro/go-zero/core/logx"
) )
@@ -48,6 +49,14 @@ func (l *TaskDetailsLogic) TaskDetails(req *types.FId) (resp *types.TaskDetailsR
} }
case "2": case "2":
l.svcCtx.DbEngin.Table("task_hpc").Where("task_id", task.Id).Scan(&subList) l.svcCtx.DbEngin.Table("task_hpc").Where("task_id", task.Id).Scan(&subList)
for _, hpc := range subList {
var cluster types.ClusterInfo
tx := l.svcCtx.DbEngin.Table("t_cluster").Where("id = ?", hpc.ClusterId).Scan(&cluster)
if tx.Error != nil {

}
hpc.WorkDir = strings.TrimPrefix(hpc.WorkDir, cluster.WorkDir)
}
} }
for _, sub := range subList { for _, sub := range subList {
clusterIds = append(clusterIds, sub.ClusterId) clusterIds = append(clusterIds, sub.ClusterId)


+ 1
- 0
internal/types/types.go View File

@@ -1267,6 +1267,7 @@ type SubTaskInfo struct {
Status string `json:"status" db:"status"` Status string `json:"status" db:"status"`
Remark string `json:"remark" db:"remark"` Remark string `json:"remark" db:"remark"`
InferUrl string `json:"inferUrl"` InferUrl string `json:"inferUrl"`
WorkDir string `json:"workDir"`
} }


type CommonResp struct { type CommonResp struct {


Loading…
Cancel
Save