|
|
|
@@ -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 |
|
|
|
} |
|
|
|
|
|
|
|
|