Browse Source

update syncreportmessage error msg

pull/446/head
tzwang 8 months ago
parent
commit
b77ee7e149
2 changed files with 10 additions and 1 deletions
  1. +6
    -1
      internal/scheduler/service/utils/jcs/middleware.go
  2. +4
    -0
      internal/scheduler/service/utils/status/taskStatusSync.go

+ 6
- 1
internal/scheduler/service/utils/jcs/middleware.go View File

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

+ 4
- 0
internal/scheduler/service/utils/status/taskStatusSync.go View File

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


Loading…
Cancel
Save