| @@ -1334,9 +1334,9 @@ func GetCloudbrainsNeededStopByRepoID(repoID int64) ([]*Cloudbrain, error) { | |||||
| return cloudBrains, err | return cloudBrains, err | ||||
| } | } | ||||
| func GetCloudbrainsByRepoIDAndJobType(repoID int64, jobType string) ([]*Cloudbrain, error) { | |||||
| func GetCloudbrainsByDisplayJobName(repoID int64, jobType string, displayJobName string) ([]*Cloudbrain, error) { | |||||
| cloudBrains := make([]*Cloudbrain, 0) | cloudBrains := make([]*Cloudbrain, 0) | ||||
| err := x.Cols("job_id", "job_name", "repo_id", "user_id", "job_type", "display_job_name").Where("repo_id=? AND job_type =?", repoID, jobType).Find(&cloudBrains) | |||||
| err := x.Cols("job_id", "job_name", "repo_id", "user_id", "job_type", "display_job_name").Where("repo_id=? AND job_type =? AND lower(display_job_name) = lower(?)", repoID, jobType, displayJobName).Find(&cloudBrains) | |||||
| return cloudBrains, err | return cloudBrains, err | ||||
| } | } | ||||
| @@ -187,7 +187,7 @@ func CloudBrainCreate(ctx *context.Context, form auth.CreateCloudBrainForm) { | |||||
| resourceSpecId := form.ResourceSpecId | resourceSpecId := form.ResourceSpecId | ||||
| repo := ctx.Repo.Repository | repo := ctx.Repo.Repository | ||||
| tasks, err := models.GetCloudbrainsByRepoIDAndJobType(repo.ID, string(models.JobTypeDebug)) | |||||
| tasks, err := models.GetCloudbrainsByDisplayJobName(repo.ID, string(models.JobTypeDebug), displayJobName) | |||||
| if err == nil { | if err == nil { | ||||
| for _, task := range tasks { | for _, task := range tasks { | ||||
| if strings.EqualFold(task.DisplayJobName, displayJobName) { | if strings.EqualFold(task.DisplayJobName, displayJobName) { | ||||
| @@ -1224,7 +1224,7 @@ func CloudBrainBenchmarkCreate(ctx *context.Context, form auth.CreateCloudBrainF | |||||
| repo := ctx.Repo.Repository | repo := ctx.Repo.Repository | ||||
| tasks, err := models.GetCloudbrainsByRepoIDAndJobType(repo.ID, string(models.JobTypeBenchmark)) | |||||
| tasks, err := models.GetCloudbrainsByDisplayJobName(repo.ID, string(models.JobTypeBenchmark), displayJobName) | |||||
| if err == nil { | if err == nil { | ||||
| for _, task := range tasks { | for _, task := range tasks { | ||||
| if strings.EqualFold(task.DisplayJobName, displayJobName) { | if strings.EqualFold(task.DisplayJobName, displayJobName) { | ||||
| @@ -205,7 +205,7 @@ func Notebook2Create(ctx *context.Context, form auth.CreateModelArtsNotebookForm | |||||
| } | } | ||||
| } | } | ||||
| tasks, err := models.GetCloudbrainsByRepoIDAndJobType(repo.ID, string(models.JobTypeDebug)) | |||||
| tasks, err := models.GetCloudbrainsByDisplayJobName(repo.ID, string(models.JobTypeDebug), displayJobName) | |||||
| if err == nil { | if err == nil { | ||||
| for _, task := range tasks { | for _, task := range tasks { | ||||
| if strings.EqualFold(task.DisplayJobName, displayJobName) { | if strings.EqualFold(task.DisplayJobName, displayJobName) { | ||||
| @@ -898,7 +898,7 @@ func TrainJobCreate(ctx *context.Context, form auth.CreateModelArtsTrainJobForm) | |||||
| return | return | ||||
| } | } | ||||
| //Determine whether the task name of the task in the project is duplicated | //Determine whether the task name of the task in the project is duplicated | ||||
| tasks, err := models.GetCloudbrainsByRepoIDAndJobType(repo.ID, string(models.JobTypeTrain)) | |||||
| tasks, err := models.GetCloudbrainsByDisplayJobName(repo.ID, string(models.JobTypeTrain), displayJobName) | |||||
| if err == nil { | if err == nil { | ||||
| for _, task := range tasks { | for _, task := range tasks { | ||||
| if strings.EqualFold(task.DisplayJobName, displayJobName) { | if strings.EqualFold(task.DisplayJobName, displayJobName) { | ||||
| @@ -1731,7 +1731,7 @@ func InferenceJobCreate(ctx *context.Context, form auth.CreateModelArtsInference | |||||
| } | } | ||||
| //Determine whether the task name of the task in the project is duplicated | //Determine whether the task name of the task in the project is duplicated | ||||
| tasks, err := models.GetCloudbrainsByRepoIDAndJobType(repo.ID, string(models.JobTypeInference)) | |||||
| tasks, err := models.GetCloudbrainsByDisplayJobName(repo.ID, string(models.JobTypeInference), displayJobName) | |||||
| if err == nil { | if err == nil { | ||||
| for _, task := range tasks { | for _, task := range tasks { | ||||
| if strings.EqualFold(task.DisplayJobName, displayJobName) { | if strings.EqualFold(task.DisplayJobName, displayJobName) { | ||||