Browse Source

增加创建模型时选择训练任务的api接口

Signed-off-by: zouap <zouap@pcl.ac.cn>
tags/v1.22.12.2^2
zouap 2 years ago
parent
commit
d8ec649a37
3 changed files with 5 additions and 5 deletions
  1. +3
    -3
      models/cloudbrain.go
  2. +1
    -1
      routers/api/v1/repo/modelmanage.go
  3. +1
    -1
      routers/repo/ai_model_manage.go

+ 3
- 3
models/cloudbrain.go View File

@@ -1823,7 +1823,7 @@ func QueryModelTrainJobVersionList(jobId string) ([]*Cloudbrain, int, error) {
return cloudbrains, int(len(cloudbrains)), nil
}

func QueryModelTrainJobList(repoId int64) ([]*CloudbrainInfo, int, error) {
func QueryModelTrainJobList(repoId int64) ([]*Cloudbrain, int, error) {
sess := x.NewSession()
defer sess.Close()
var cond = builder.NewCond()
@@ -1840,14 +1840,14 @@ func QueryModelTrainJobList(repoId int64) ([]*CloudbrainInfo, int, error) {
// builder.In("type", 0, 1),
// )

cloudbrains := make([]*CloudbrainInfo, 0)
cloudbrains := make([]*Cloudbrain, 0)
if err := sess.Select("job_id,display_job_name").Table(&Cloudbrain{}).Where(cond).OrderBy("created_unix DESC").
Find(&cloudbrains); err != nil {
return nil, 0, fmt.Errorf("Find: %v", err)
}

keys := make(map[string]string)
uniqueElements := make([]*CloudbrainInfo, 0)
uniqueElements := make([]*Cloudbrain, 0)
for _, entry := range cloudbrains {
if _, value := keys[entry.JobID]; !value {
keys[entry.JobID] = entry.DisplayJobName


+ 1
- 1
routers/api/v1/repo/modelmanage.go View File

@@ -64,7 +64,7 @@ func QueryTrainJobList(ctx *context.APIContext) {
} else {
re := make([]*api.Cloudbrain, 0)
for _, task := range result {
conRe := convert.ToCloudBrain(&task.Cloudbrain)
conRe := convert.ToCloudBrain(task)
re = append(re, conRe)
}
ctx.JSON(http.StatusOK, re)


+ 1
- 1
routers/repo/ai_model_manage.go View File

@@ -741,7 +741,7 @@ func QueryTrainJobList(ctx *context.Context) {
}
}

func QueryTrainJobListApi(ctx *context.Context) ([]*models.CloudbrainInfo, error) {
func QueryTrainJobListApi(ctx *context.Context) ([]*models.Cloudbrain, error) {
repoId := ctx.QueryInt64("repoId")
VersionListTasks, count, err := models.QueryModelTrainJobList(repoId)
log.Info("query return count=" + fmt.Sprint(count))


Loading…
Cancel
Save