fix log bugs

Former-commit-id: 92a183cafa

api/internal/logic/ai/getcentertasklistlogic.go

@@ -92,7 +92,7 @@ func (l *GetCenterTaskListLogic) updateAiTaskStatus(mu *sync.RWMutex, ch chan<-
 		}
 		for _, task := range taskList {
 			t := task
-			if t.Status == constants.Completed {
+			if t.Status == constants.Completed || t.JobId == "" {
 				continue
 			}
 			wg.Add(1)

api/internal/scheduler/schedulers/aiScheduler.go

@@ -197,7 +197,7 @@ func (as *AiScheduler) AssignTask(clusters []*strategy.AssignedCluster) (interfa
 				return nil, errors.New("database add failed: " + err.Error())
 			}
 		}
-		for s := range ch {
+		for _, s := range results {
 			if s.Msg != "" {
 				msg := fmt.Sprintf("clusterId: %v , error: %v \n", s.ClusterId, s.Msg)
 				errmsg += msg

api/internal/storeLink/octopus.go

@@ -471,6 +471,10 @@ func (o *OctopusLink) GetTrainingTaskLog(ctx context.Context, taskId string, ins
 		return "", err
 	}
 
+	if strings.Contains(resp.Content, "404 Not Found") {
+		resp.Content = "waiting for logs..."
+	}
+
 	return resp.Content, nil
 }