forked from JointCloud/pcm-coordinator
存算联动调整5
This commit is contained in:
parent
2a1ae75d61
commit
f59160f417
|
@ -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_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)
|
||||
|
@ -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)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
Loading…
Reference in New Issue