From c4963f2a41c4e107cf50bb637c1fd301cdb31d3c Mon Sep 17 00:00:00 2001
From: zhangwei <894646498@qq.com>
Date: Mon, 3 Mar 2025 15:32:12 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E8=B6=85=E7=AE=97=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E4=B8=8A=E9=93=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/logic/hpc/commithpctasklogic.go | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

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
 }