zhangweiii
/
pcm-coordinator
forked from JointCloud/pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request 'updated tasklog' (#515) from tzwang/pcm-coordinator:master into master

This commit is contained in:
tzwang 2025-06-26 10:39:00 +08:00
parent 5152c9162e cb7325393f
commit 1d1915bed2
3 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/handler/schedule/schedulegetaijoblogloghandler.go
View File

@ -7,22 +7,19 @@ import (
"gitlink.org.cn/JointCloud/pcm-coordinator/internal/logic/schedule"
"gitlink.org.cn/JointCloud/pcm-coordinator/internal/svc"
"gitlink.org.cn/JointCloud/pcm-coordinator/internal/types"
"gitlink.org.cn/JointCloud/pcm-coordinator/pkg/repository/result"
)
func ScheduleGetAiJobLogLogHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
var req types.AiJobLogReq
if err := httpx.Parse(r, &req); err != nil {
httpx.ErrorCtx(r.Context(), w, err)
result.ParamErrorResult(r, w, err)
return
}
l := schedule.NewScheduleGetAiJobLogLogLogic(r.Context(), svcCtx)
resp, err := l.ScheduleGetAiJobLogLog(&req)
if err != nil {
httpx.ErrorCtx(r.Context(), w, err)
} else {
httpx.OkJsonCtx(r.Context(), w, resp)
}
result.HttpResult(r, w, resp, err)
}
}

4
internal/logic/core/taskdetailslogic.go
View File

@ -70,3 +70,7 @@ func (l *TaskDetailsLogic) TaskDetails(req *types.FId) (resp *types.TaskDetailsR
resp.SubTaskInfos = subList
return
}
func (l *TaskDetailsLogic) deployTaskDetail() {
//l.svcCtx.Scheduler.AiStorages.GetInferDeployInstanceById()
}

2
internal/storeLink/openi.go
View File

@ -671,7 +671,7 @@ func (o *OpenI) GetTrainingTaskLog(ctx context.Context, taskId string, instanceN
Send()
if err != nil {
return "", errors.New("failed to invoke taskDetails")
return "", err
}
if resp.Data == "" {