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

提交超算任务上链

This commit is contained in:
zhangwei 2025-03-03 15:32:12 +08:00
parent fffa8f1d7e
commit c4963f2a41
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
internal/logic/hpc/commithpctasklogic.go
View File

@ -93,12 +93,6 @@ func (l *CommitHpcTaskLogic) CommitHpcTask(req *types.CommitHpcTaskReq) (resp *t
if tx.Error != nil { if tx.Error != nil {
return nil, tx.Error return nil, tx.Error
} }
// 提交job到指定集群
logx.Info("提交job到指定集群")
go func() {
submitJob(&hpcInfo, &clusterInfo, server)
}()
// 保存操作记录 // 保存操作记录
noticeInfo := clientCore.NoticeInfo{ noticeInfo := clientCore.NoticeInfo{
AdapterId: clusterInfo.AdapterId, AdapterId: clusterInfo.AdapterId,
@ -128,6 +122,11 @@ func (l *CommitHpcTaskLogic) CommitHpcTask(req *types.CommitHpcTaskReq) (resp *t
Token: req.Token, Token: req.Token,
Args: []string{strconv.FormatInt(taskModel.Id, 10), string(bytes)}, Args: []string{strconv.FormatInt(taskModel.Id, 10), string(bytes)},
}) })
// 提交job到指定集群
logx.Info("提交job到指定集群")
go func() {
submitJob(&hpcInfo, &clusterInfo, server)
}()
return resp, nil return resp, nil
} }