|
@@ -962,13 +962,23 @@ func QueryModelTrainJobList(repoId int64) ([]*CloudbrainInfo, int, error) { |
|
|
cond = cond.And( |
|
|
cond = cond.And( |
|
|
builder.Eq{"Status": "COMPLETED"}, |
|
|
builder.Eq{"Status": "COMPLETED"}, |
|
|
) |
|
|
) |
|
|
sess.OrderBy("job_id DESC") |
|
|
|
|
|
|
|
|
|
|
|
cloudbrains := make([]*CloudbrainInfo, 0) |
|
|
cloudbrains := make([]*CloudbrainInfo, 0) |
|
|
if err := sess.Distinct("job_id,job_name").Table(&Cloudbrain{}).Where(cond). |
|
|
|
|
|
|
|
|
if err := sess.Select("job_id,job_name").Table(&Cloudbrain{}).Where(cond).OrderBy("created_unix DESC"). |
|
|
Find(&cloudbrains); err != nil { |
|
|
Find(&cloudbrains); err != nil { |
|
|
return nil, 0, fmt.Errorf("Find: %v", err) |
|
|
return nil, 0, fmt.Errorf("Find: %v", err) |
|
|
} |
|
|
} |
|
|
return cloudbrains, int(len(cloudbrains)), nil |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
keys := make(map[string]string) |
|
|
|
|
|
uniqueElements := make([]*CloudbrainInfo, 0) |
|
|
|
|
|
for _, entry := range cloudbrains { |
|
|
|
|
|
if _, value := keys[entry.JobID]; !value { |
|
|
|
|
|
keys[entry.JobID] = entry.JobName |
|
|
|
|
|
uniqueElements = append(uniqueElements, entry) |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return uniqueElements, int(len(uniqueElements)), nil |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func CloudbrainsVersionList(opts *CloudbrainsOptions) ([]*CloudbrainInfo, int, error) { |
|
|
func CloudbrainsVersionList(opts *CloudbrainsOptions) ([]*CloudbrainInfo, int, error) { |
|
|