提交超算任务上链

This commit is contained in:
zhangwei 2025-03-03 15:13:45 +08:00
parent df03f35a67
commit fffa8f1d7e
1 changed files with 4 additions and 2 deletions

View File

@ -95,7 +95,9 @@ func (l *CommitHpcTaskLogic) CommitHpcTask(req *types.CommitHpcTaskReq) (resp *t
}
// 提交job到指定集群
logx.Info("提交job到指定集群")
jobId, err := submitJob(&hpcInfo, &clusterInfo, server)
go func() {
submitJob(&hpcInfo, &clusterInfo, server)
}()
// 保存操作记录
noticeInfo := clientCore.NoticeInfo{
@ -113,7 +115,7 @@ func (l *CommitHpcTaskLogic) CommitHpcTask(req *types.CommitHpcTaskReq) (resp *t
logx.Errorf("Task creation failure, err: %v", result.Error)
}
resp = &types.CommitHpcTaskResp{
JobId: string(jobId),
JobId: string(""),
}
// 数据上链
bytes, _ := json.Marshal(taskModel)