|
|
|
@@ -98,13 +98,17 @@ func (s *TaskStatus) UpdateTaskStatus(tasklist []*types.TaskModel) { |
|
|
|
logx.Errorf("############ Report Status Message Before Sending %s", task.Status) |
|
|
|
|
|
|
|
err = s.reportStatusMessages(task, aiTask[0]) |
|
|
|
logx.Errorf("reportStatusMessages Error %s", err.Error()) |
|
|
|
if err != nil { |
|
|
|
logx.Errorf("reportStatusMessages Error %s", err.Error()) |
|
|
|
} |
|
|
|
case constants.Failed: |
|
|
|
task.Status = constants.Failed |
|
|
|
logx.Errorf("############ Report Status Message Before Sending %s", task.Status) |
|
|
|
|
|
|
|
err = s.reportStatusMessages(task, aiTask[0]) |
|
|
|
logx.Errorf("reportStatusMessages Error %s", err.Error()) |
|
|
|
if err != nil { |
|
|
|
logx.Errorf("reportStatusMessages Error %s", err.Error()) |
|
|
|
} |
|
|
|
|
|
|
|
default: |
|
|
|
task.Status = aiTask[0].Status |
|
|
|
|