routers/repo/cloudbrain.go

@@ -1495,7 +1495,7 @@ func DeleteJobsByRepoID(repoID int64) {
 		log.Warn("Failed to get cloudBrain info", err)
 		return
 	}
-	DeleteJobs(cloudBrains)
+	ai_task.DelCloudbrains(cloudBrains)
 }
 
 /*

services/ai_task_service/task/task_service.go

@@ -832,6 +832,16 @@ func DelCloudbrain(task *models.Cloudbrain) *response.BizError {
 	return t.Delete(task.ID)
 }
 
+func DelCloudbrains(tasks []*models.Cloudbrain) *response.BizError {
+	for _, t := range tasks {
+		err := DelCloudbrain(t)
+		if err != nil {
+			log.Error("delete cloudbrain err.id=%d err=%v", t.ID, err)
+		}
+	}
+	return nil
+}
+
 func HandleNewAITaskStop(cloudbrainId int64) (result *entity.AITaskBriefInfo, isHandled bool, err error) {
 	task, err := models.GetCloudbrainByCloudbrainID(cloudbrainId)
 	if err != nil {