|
|
@@ -620,12 +620,17 @@ func TrainJobNewVersion(ctx *context.Context) { |
|
|
func trainJobNewVersionDataPrepare(ctx *context.Context) error { |
|
|
func trainJobNewVersionDataPrepare(ctx *context.Context) error { |
|
|
ctx.Data["PageIsCloudBrain"] = true |
|
|
ctx.Data["PageIsCloudBrain"] = true |
|
|
var jobID = ctx.Params(":jobid") |
|
|
var jobID = ctx.Params(":jobid") |
|
|
var versionName = ctx.Query("versionName") |
|
|
|
|
|
jobID = "19373" |
|
|
|
|
|
|
|
|
var versionName = ctx.Query("version_name") |
|
|
|
|
|
|
|
|
|
|
|
task, err := models.GetCloudbrainByJobIDAndVersionName(jobID, versionName) |
|
|
|
|
|
if err != nil { |
|
|
|
|
|
log.Error("GetCloudbrainByJobIDAndVersionName(%s) failed:%v", jobID, err.Error()) |
|
|
|
|
|
return err |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
t := time.Now() |
|
|
t := time.Now() |
|
|
var jobName = cutString(ctx.User.Name, 5) + t.Format("2006010215") + strconv.Itoa(int(t.Unix()))[5:] |
|
|
var jobName = cutString(ctx.User.Name, 5) + t.Format("2006010215") + strconv.Itoa(int(t.Unix()))[5:] |
|
|
ctx.Data["job_name"] = jobName |
|
|
|
|
|
|
|
|
ctx.Data["job_name"] = task.JobName |
|
|
|
|
|
|
|
|
attachs, err := models.GetModelArtsUserAttachments(ctx.User.ID) |
|
|
attachs, err := models.GetModelArtsUserAttachments(ctx.User.ID) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
@@ -670,10 +675,14 @@ func trainJobNewVersionDataPrepare(ctx *context.Context) error { |
|
|
ctx.ServerError("GetBranches error:", err) |
|
|
ctx.ServerError("GetBranches error:", err) |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
ctx.Data["Branches"] = Branches |
|
|
|
|
|
ctx.Data["BranchesCount"] = len(Branches) |
|
|
|
|
|
ctx.Data["jobID"] = jobID |
|
|
|
|
|
ctx.Data["versionName"] = versionName |
|
|
|
|
|
|
|
|
ctx.Data["branches"] = Branches |
|
|
|
|
|
ctx.Data["branch_name"] = task.BranchName |
|
|
|
|
|
ctx.Data["description"] = task.Description |
|
|
|
|
|
ctx.Data["boot_file"] = task.BootFile |
|
|
|
|
|
ctx.Data["dataset_name"] = task.DatasetName |
|
|
|
|
|
ctx.Data["params"] = task.Parameters |
|
|
|
|
|
ctx.Data["work_server_number"] = task.WorkServerNumber |
|
|
|
|
|
ctx.Data["flavor_name"] = task.FlavorName |
|
|
|
|
|
|
|
|
configList, err := getConfigList(modelarts.PerPage, 1, modelarts.SortByCreateTime, "desc", "", modelarts.ConfigTypeCustom) |
|
|
configList, err := getConfigList(modelarts.PerPage, 1, modelarts.SortByCreateTime, "desc", "", modelarts.ConfigTypeCustom) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
@@ -705,6 +714,7 @@ func TrainJobCreate(ctx *context.Context, form auth.CreateModelArtsTrainJobForm) |
|
|
dataPath := "/" + setting.Bucket + "/" + setting.BasePath + path.Join(uuid[0:1], uuid[1:2]) + "/" + uuid + uuid + "/" |
|
|
dataPath := "/" + setting.Bucket + "/" + setting.BasePath + path.Join(uuid[0:1], uuid[1:2]) + "/" + uuid + uuid + "/" |
|
|
branch_name := form.BranchName |
|
|
branch_name := form.BranchName |
|
|
isLatestVersion := modelarts.IsLatestVersion |
|
|
isLatestVersion := modelarts.IsLatestVersion |
|
|
|
|
|
FlavorName := form.FlavorName |
|
|
|
|
|
|
|
|
if err := paramCheckCreateTrainJob(form); err != nil { |
|
|
if err := paramCheckCreateTrainJob(form); err != nil { |
|
|
log.Error("paramCheckCreateTrainJob failed:(%v)", err) |
|
|
log.Error("paramCheckCreateTrainJob failed:(%v)", err) |
|
|
@@ -851,6 +861,7 @@ func TrainJobCreate(ctx *context.Context, form auth.CreateModelArtsTrainJobForm) |
|
|
BranchName: branch_name, |
|
|
BranchName: branch_name, |
|
|
Params: form.Params, |
|
|
Params: form.Params, |
|
|
FatherVersionName: modelarts.InitFatherVersionName, |
|
|
FatherVersionName: modelarts.InitFatherVersionName, |
|
|
|
|
|
FlavorName: FlavorName, |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
err = modelarts.GenerateTrainJob(ctx, req) |
|
|
err = modelarts.GenerateTrainJob(ctx, req) |
|
|
@@ -921,6 +932,7 @@ func TrainJobCreateVersion(ctx *context.Context, form auth.CreateModelArtsTrainJ |
|
|
dataPath := "/" + setting.Bucket + "/" + setting.BasePath + path.Join(uuid[0:1], uuid[1:2]) + "/" + uuid + uuid + "/" |
|
|
dataPath := "/" + setting.Bucket + "/" + setting.BasePath + path.Join(uuid[0:1], uuid[1:2]) + "/" + uuid + uuid + "/" |
|
|
branch_name := form.BranchName |
|
|
branch_name := form.BranchName |
|
|
fatherVersionName := form.VersionName |
|
|
fatherVersionName := form.VersionName |
|
|
|
|
|
FlavorName := form.FlavorName |
|
|
|
|
|
|
|
|
if err := paramCheckCreateTrainJob(form); err != nil { |
|
|
if err := paramCheckCreateTrainJob(form); err != nil { |
|
|
log.Error("paramCheckCreateTrainJob failed:(%v)", err) |
|
|
log.Error("paramCheckCreateTrainJob failed:(%v)", err) |
|
|
@@ -1070,6 +1082,7 @@ func TrainJobCreateVersion(ctx *context.Context, form auth.CreateModelArtsTrainJ |
|
|
PreVersionId: task.VersionID, |
|
|
PreVersionId: task.VersionID, |
|
|
CommitID: commitID, |
|
|
CommitID: commitID, |
|
|
BranchName: branch_name, |
|
|
BranchName: branch_name, |
|
|
|
|
|
FlavorName: FlavorName, |
|
|
} |
|
|
} |
|
|
err = modelarts.GenerateTrainJobVersion(ctx, req, jobID, fatherVersionName) |
|
|
err = modelarts.GenerateTrainJobVersion(ctx, req, jobID, fatherVersionName) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
|