| @@ -1,6 +1,10 @@ | |||
| package dataset | |||
| import "code.gitea.io/gitea/models" | |||
| import ( | |||
| "strings" | |||
| "code.gitea.io/gitea/models" | |||
| ) | |||
| func GetResourceType(cloudbrainType int) string { | |||
| if cloudbrainType == 0 { | |||
| @@ -33,3 +37,23 @@ func IsShowDataSetOfCurrentRepo(repoID int64) bool { | |||
| return true | |||
| } | |||
| func GetFilterDeletedAttachments(uuids string) (string, string) { | |||
| attachments, err := models.GetAttachmentsByUUIDs(strings.Split(uuids, ";")) | |||
| if err != nil { | |||
| return "", "" | |||
| } | |||
| uuidR := "" | |||
| filenames := "" | |||
| for i, attachment := range attachments { | |||
| if i == 0 { | |||
| uuidR += attachment.UUID | |||
| filenames += attachment.Name | |||
| } else { | |||
| uuidR += ";" + attachment.UUID | |||
| filenames += ";" + attachment.Name | |||
| } | |||
| } | |||
| return uuidR, filenames | |||
| } | |||
| @@ -15,6 +15,8 @@ import ( | |||
| "time" | |||
| "unicode/utf8" | |||
| "code.gitea.io/gitea/modules/dataset" | |||
| "code.gitea.io/gitea/services/cloudbrain/resource" | |||
| "code.gitea.io/gitea/services/reward/point/account" | |||
| @@ -158,16 +160,10 @@ func cloudBrainNewDataPrepare(ctx *context.Context) error { | |||
| ctx.Data["model_version"] = ctx.Cloudbrain.ModelVersion | |||
| ctx.Data["pre_train_model_url"] = ctx.Cloudbrain.PreTrainModelUrl | |||
| ctx.Data["compute_resource"] = ctx.Cloudbrain.ComputeResource | |||
| ctx.Data["attachment"] = ctx.Cloudbrain.Uuid | |||
| uuids, datasetNames := dataset.GetFilterDeletedAttachments(ctx.Cloudbrain.Uuid) | |||
| ctx.Data["attachment"] = uuids | |||
| ctx.Data["dataset_name"] = datasetNames | |||
| ctx.Data["cluster_type"] = models.OpenICluster | |||
| _, _, datasetNames, _, err := getDatasUrlListByUUIDS(ctx.Cloudbrain.Uuid) | |||
| if err != nil { | |||
| log.Info("query dataset error," + err.Error()) | |||
| ctx.Data["dataset_name"] = "" | |||
| } else { | |||
| ctx.Data["dataset_name"] = datasetNames | |||
| } | |||
| } | |||
| return nil | |||
| @@ -12,6 +12,8 @@ import ( | |||
| "strings" | |||
| "time" | |||
| "code.gitea.io/gitea/modules/dataset" | |||
| "code.gitea.io/gitea/services/cloudbrain/resource" | |||
| "code.gitea.io/gitea/services/reward/point/account" | |||
| @@ -141,20 +143,21 @@ func grampusTrainJobNewDataPrepare(ctx *context.Context, processType string) err | |||
| } | |||
| if ctx.Cloudbrain != nil { | |||
| ctx.Data["attachment"] = ctx.Cloudbrain.Uuid | |||
| uuids, datasetNames := dataset.GetFilterDeletedAttachments(ctx.Cloudbrain.Uuid) | |||
| ctx.Data["attachment"] = uuids | |||
| ctx.Data["boot_file"] = ctx.Cloudbrain.BootFile | |||
| ctx.Data["image_id"] = ctx.Cloudbrain.ImageID | |||
| ctx.Data["run_para_list"] = ctx.Cloudbrain.Parameters | |||
| ctx.Data["description"] = ctx.Cloudbrain.Description | |||
| ctx.Data["branch_name"] = ctx.Cloudbrain.BranchName | |||
| ctx.Data["engine_name"] = ctx.Cloudbrain.EngineName | |||
| ctx.Data["WorkServerNumber"] = ctx.Cloudbrain.WorkServerNumber | |||
| ctx.Data["work_server_number"] = ctx.Cloudbrain.WorkServerNumber | |||
| if ctx.Cloudbrain.Image != "" { | |||
| ctx.Data["image"] = ctx.Cloudbrain.Image | |||
| } else { | |||
| ctx.Data["image"] = ctx.Cloudbrain.EngineName | |||
| } | |||
| ctx.Data["dataset_name"] = ctx.Cloudbrain.DatasetName | |||
| ctx.Data["dataset_name"] = datasetNames | |||
| ctx.Data["model_name"] = ctx.Cloudbrain.ModelName | |||
| ctx.Data["model_version"] = ctx.Cloudbrain.ModelVersion | |||
| @@ -15,6 +15,8 @@ import ( | |||
| "time" | |||
| "unicode/utf8" | |||
| "code.gitea.io/gitea/modules/dataset" | |||
| "code.gitea.io/gitea/modules/modelarts_cd" | |||
| "code.gitea.io/gitea/services/cloudbrain/resource" | |||
| "code.gitea.io/gitea/services/reward/point/account" | |||
| @@ -931,14 +933,11 @@ func trainJobNewVersionDataPrepare(ctx *context.Context) error { | |||
| ctx.ServerError("GetBranches error:", err) | |||
| return err | |||
| } | |||
| _, _, datasetNames, _, err := getDatasUrlListByUUIDS(task.Uuid) | |||
| if err != nil { | |||
| log.Info("query dataset error," + err.Error()) | |||
| //ctx.ServerError("GetAllUserAttachments failed:", err) | |||
| //return err | |||
| } else { | |||
| ctx.Data["dataset_name"] = datasetNames | |||
| } | |||
| uuids, datasetNames := dataset.GetFilterDeletedAttachments(task.Uuid) | |||
| ctx.Data["dataset_name"] = datasetNames | |||
| ctx.Data["branches"] = branches | |||
| ctx.Data["branch_name"] = task.BranchName | |||
| ctx.Data["description"] = task.Description | |||
| @@ -947,7 +946,7 @@ func trainJobNewVersionDataPrepare(ctx *context.Context) error { | |||
| ctx.Data["work_server_number"] = task.WorkServerNumber | |||
| ctx.Data["flavor_name"] = task.FlavorName | |||
| ctx.Data["engine_name"] = task.EngineName | |||
| ctx.Data["attachment"] = task.Uuid | |||
| ctx.Data["attachment"] = uuids | |||
| ctx.Data["flavor_code"] = task.FlavorCode | |||
| ctx.Data["engine_id"] = task.EngineID | |||
| ctx.Data["datasetType"] = models.TypeCloudBrainTwo | |||