|
@@ -17,17 +17,13 @@ import ( |
|
|
uuid "github.com/satori/go.uuid" |
|
|
uuid "github.com/satori/go.uuid" |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
|
func SaveModelByParameters(trainTaskId int64, name string, version string, label string, description string, userId int64) { |
|
|
|
|
|
aiTasks, count, err := models.Cloudbrains(&models.CloudbrainsOptions{ |
|
|
|
|
|
JobID: trainTaskId, |
|
|
|
|
|
Type: -1, |
|
|
|
|
|
}) |
|
|
|
|
|
|
|
|
func SaveModelByParameters(trainTaskId string, name string, version string, label string, description string, userId int64) { |
|
|
|
|
|
aiTask, err := models.GetCloudbrainByJobID(trainTaskId) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Info("query task error." + err.Error()) |
|
|
log.Info("query task error." + err.Error()) |
|
|
//ctx.Error(500, fmt.Sprintf("query cloud brain train task error. %v", err)) |
|
|
//ctx.Error(500, fmt.Sprintf("query cloud brain train task error. %v", err)) |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|
log.Info("query return count=" + fmt.Sprint(count)) |
|
|
|
|
|
|
|
|
|
|
|
uuid := uuid.NewV4() |
|
|
uuid := uuid.NewV4() |
|
|
id := uuid.String() |
|
|
id := uuid.String() |
|
@@ -36,12 +32,6 @@ func SaveModelByParameters(trainTaskId int64, name string, version string, label |
|
|
var modelSize int64 |
|
|
var modelSize int64 |
|
|
cloudType := models.TypeCloudBrainTwo |
|
|
cloudType := models.TypeCloudBrainTwo |
|
|
|
|
|
|
|
|
if len(aiTasks) != 1 { |
|
|
|
|
|
log.Info("query task error. len=" + fmt.Sprint(len(aiTasks))) |
|
|
|
|
|
//ctx.Error(500, fmt.Sprintf("query cloud brain train task error. %v", err)) |
|
|
|
|
|
return |
|
|
|
|
|
} |
|
|
|
|
|
aiTask := aiTasks[0] |
|
|
|
|
|
log.Info("find task name:" + aiTask.JobName) |
|
|
log.Info("find task name:" + aiTask.JobName) |
|
|
aimodels := models.QueryModelByName(name, userId) |
|
|
aimodels := models.QueryModelByName(name, userId) |
|
|
if len(aimodels) > 0 { |
|
|
if len(aimodels) > 0 { |
|
@@ -51,7 +41,7 @@ func SaveModelByParameters(trainTaskId int64, name string, version string, label |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
cloudType = aiTask.Cloudbrain.Type |
|
|
|
|
|
|
|
|
cloudType = aiTask.Type |
|
|
//download model zip //train type |
|
|
//download model zip //train type |
|
|
if cloudType == models.TypeCloudBrainTrainJob { |
|
|
if cloudType == models.TypeCloudBrainTrainJob { |
|
|
modelPath, modelSize, err = downloadModelFromCloudBrainTwo(id, aiTask.JobName, "") |
|
|
modelPath, modelSize, err = downloadModelFromCloudBrainTwo(id, aiTask.JobName, "") |
|
|