floraachy
/
pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

存算联动调整5 

Former-commit-id: f59160f417653127ae91b28e65404e440c8f09b3
This commit is contained in:
tzwang 2023-12-08 11:20:58 +08:00
parent d7556a9c1f
commit 1d296f2155
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
api/internal/storeLink/shuguangHpc.go
View File

@ -161,7 +161,7 @@ func (s ShuguangHpc) SubmitTask(imageId string, cmd string, envs []string, param
} }
//请求 //请求
taskName := TASK_SHUGUANG_PREFIX + UNDERSCORE + UNDERSCORE + utils.RandomString(10) taskName := TASK_SHUGUANG_PREFIX + UNDERSCORE + utils.RandomString(10)
GAP_WORK_DIR := strings.Replace(GAP_WORK_DIR, JOBNAME, taskName, -1) GAP_WORK_DIR := strings.Replace(GAP_WORK_DIR, JOBNAME, taskName, -1)
GAP_STD_OUT_FILE := strings.Replace(GAP_STD_OUT_FILE, JOBNAME, taskName, -1) GAP_STD_OUT_FILE := strings.Replace(GAP_STD_OUT_FILE, JOBNAME, taskName, -1)
GAP_STD_ERR_FILE := strings.Replace(GAP_STD_ERR_FILE, JOBNAME, taskName, -1) GAP_STD_ERR_FILE := strings.Replace(GAP_STD_ERR_FILE, JOBNAME, taskName, -1)
@ -220,7 +220,7 @@ func (s ShuguangHpc) QueryTask(taskId string) (interface{}, error) {
} }
//实时作业检查是否成功 //实时作业检查是否成功
if respC.Data != nil { if respC.Data != nil && respC.Data.JobEndTime != "" {
taskRespC, err := ConvertType[hpcAC.GetJobDetailResp](respC, nil) taskRespC, err := ConvertType[hpcAC.GetJobDetailResp](respC, nil)
if err != nil { if err != nil {
return nil, err return nil, err