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