annzee
/
PCM
forked from JCCE/PCM
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1proto更新

This commit is contained in:
lee 2023-02-24 19:23:10 +08:00
parent a9d119ab44
commit 62ea8480d7
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
adaptor/AIComputing/modelarts/rpc/internal/logic/listjoblogic.go
View File

@ -53,13 +53,27 @@ func (l *ListJobLogic) ListJob(in *modelarts.ListImportTasks) (*modelarts.Return
body, err := ioutil.ReadAll(respUrl.Body)
jsonResult, err := simplejson.NewJson(body)
if jsonResult.Get("total_count").MustInt() != 0 {
resp.TotalCount = 2
if jsonResult.Get("total_count").MustInt() == 0 {
resp.TotalCount = 0
resp.ImportTasks = nil
return &resp, nil
}
TasksData, err := jsonResult.Get("import_tasks").Array()
//demo,err := TasksData.
println(TasksData)
var Jobs []*modelarts.ImportTasks
taskList := jsonResult.Get("import_tasks")
rows, err := taskList.Array()
for index := range rows {
task := taskList.GetIndex(index)
var job modelarts.ImportTasks
println(task)
job.Status = task.Get("status").MustString()
//startTime, err := time.Parse(l.svcCtx.Config.ShuguangConf.Layout, jobShuguang.Get("jobStartTime").MustString())
//if err == nil {
// job.JobStartTime = startTime.String()
//}
Jobs = append(Jobs, &job)
}
resp.TotalCount = uint32(jsonResult.Get("total_count").MustInt())
resp.ImportTasks = Jobs
return &resp, nil
}