|
|
|
@@ -51,7 +51,7 @@ func (s *TaskStatus) UpdateAiTaskStatus(tasklist []*types.TaskModel) { |
|
|
|
for _, task := range list { |
|
|
|
aiTaskList, err := s.aiStorages.GetAiTaskListById(task.Id) |
|
|
|
if err != nil { |
|
|
|
panic(err.Error()) |
|
|
|
logx.Errorf("UpdateAiTaskStatus Get AiTask Error %s", err.Error()) |
|
|
|
} |
|
|
|
|
|
|
|
if len(aiTaskList) == 0 { |
|
|
|
@@ -81,7 +81,7 @@ func (s *TaskStatus) UpdateTaskStatus(tasklist []*types.TaskModel) { |
|
|
|
for _, task := range list { |
|
|
|
aiTask, err := s.aiStorages.GetAiTaskListById(task.Id) |
|
|
|
if err != nil { |
|
|
|
panic(err.Error()) |
|
|
|
logx.Errorf("UpdateTaskStatus Get AiTask Error %s", err.Error()) |
|
|
|
} |
|
|
|
|
|
|
|
if len(aiTask) == 0 { |
|
|
|
@@ -111,7 +111,7 @@ func (s *TaskStatus) UpdateTaskStatus(tasklist []*types.TaskModel) { |
|
|
|
task.EndTime = aiTask[0].EndTime |
|
|
|
err := s.aiStorages.UpdateTask(task) |
|
|
|
if err != nil { |
|
|
|
panic(err.Error()) |
|
|
|
logx.Errorf("UpdateTaskStatus Update Task Error %s", err.Error()) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|