From b77ee7e1496b077c31074a33e0ab8746faf2fea1 Mon Sep 17 00:00:00 2001 From: tzwang Date: Fri, 14 Mar 2025 16:45:33 +0800 Subject: [PATCH] update syncreportmessage error msg --- internal/scheduler/service/utils/jcs/middleware.go | 7 ++++++- internal/scheduler/service/utils/status/taskStatusSync.go | 4 ++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/internal/scheduler/service/utils/jcs/middleware.go b/internal/scheduler/service/utils/jcs/middleware.go index 9179e8f9..30ac877d 100644 --- a/internal/scheduler/service/utils/jcs/middleware.go +++ b/internal/scheduler/service/utils/jcs/middleware.go @@ -1,6 +1,7 @@ package jcs import ( + "github.com/zeromicro/go-zero/core/logx" "gitlink.org.cn/JointCloud/pcm-openi/common" ) @@ -24,15 +25,19 @@ func StatusReport(url string, report *JobStatusReportReq) error { }{} req := common.GetRestyRequest(common.TIMEOUT) - _, err := req. + rp, err := req. SetHeader("Content-Type", "application/json"). SetBody(report). SetResult(&resp). Post(url) if err != nil { + logx.Errorf("############ Report Status Message Error %s", err.Error()) + return err } + logx.Errorf("############ Report Status Message After Sending %s", string(rp.Body())) + return nil } diff --git a/internal/scheduler/service/utils/status/taskStatusSync.go b/internal/scheduler/service/utils/status/taskStatusSync.go index c7b73f7e..6ba85897 100644 --- a/internal/scheduler/service/utils/status/taskStatusSync.go +++ b/internal/scheduler/service/utils/status/taskStatusSync.go @@ -66,9 +66,13 @@ func UpdateTaskStatus(svc *svc.ServiceContext, tasklist []*types.TaskModel) { switch aiTask[0].Status { case constants.Completed: task.Status = constants.Succeeded + logx.Errorf("############ Report Status Message Before Sending %s", task.Status) + _ = reportStatusMessages(svc, task, aiTask[0]) case constants.Failed: task.Status = constants.Failed + logx.Errorf("############ Report Status Message Before Sending %s", task.Status) + _ = reportStatusMessages(svc, task, aiTask[0]) default: task.Status = aiTask[0].Status