Merge pull request 'updated taskSync' (#470) from tzwang/pcm-coordinator:master into master

internal/scheduler/service/utils/status/statusSync.go

@@ -97,12 +97,15 @@ func (s *TaskStatus) UpdateTaskStatus(tasklist []*types.TaskModel) {
 				task.Status = constants.Succeeded
 				logx.Errorf("############ Report Status Message Before Sending %s", task.Status)
 
-				_ = s.reportStatusMessages(task, aiTask[0])
+				err = s.reportStatusMessages(task, aiTask[0])
+				logx.Errorf("reportStatusMessages Error %s", err.Error())
 			case constants.Failed:
 				task.Status = constants.Failed
 				logx.Errorf("############ Report Status Message Before Sending %s", task.Status)
 
-				_ = s.reportStatusMessages(task, aiTask[0])
+				err = s.reportStatusMessages(task, aiTask[0])
+				logx.Errorf("reportStatusMessages Error %s", err.Error())
+
 			default:
 				task.Status = aiTask[0].Status
 			}
@@ -206,9 +209,12 @@ func (s *TaskStatus) reportStatusMessages(task *types.TaskModel, aiTask *models.
 	}
 	report.Messages = append(report.Messages, jobMsg)
 
-	_ = jcs.StatusReport(s.config.JcsMiddleware.JobStatusReportUrl, report)
+	err := jcs.StatusReport(s.config.JcsMiddleware.JobStatusReportUrl, report)
+	if err != nil {
+		return err
+	}
 
-	err := jcs.TempSaveReportToTask(s.aiStorages, task, report)
+	err = jcs.TempSaveReportToTask(s.aiStorages, task, report)
 	if err != nil {
 		return err
 	}