diff --git a/adaptor/AIComputing/modelarts/rpc/internal/logic/listjoblogic.go b/adaptor/AIComputing/modelarts/rpc/internal/logic/listjoblogic.go index 2561d65..c9e7721 100644 --- a/adaptor/AIComputing/modelarts/rpc/internal/logic/listjoblogic.go +++ b/adaptor/AIComputing/modelarts/rpc/internal/logic/listjoblogic.go @@ -64,13 +64,13 @@ func (l *ListJobLogic) ListJob(in *modelarts.ListImportTasks) (*modelarts.Return 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() - //} - + job.TaskId = task.Get("task_id").MustString() + job.DatasetId = task.Get("dataset_id").MustString() + job.ImportPath = task.Get("import_path").MustString() + job.ImportType = int32(task.Get("import_type").MustInt()) + job.TotalSampleCount = uint32(task.Get("total_sample_count").MustInt()) + job.ImportedSampleCount = uint32(task.Get("imported_sample_count").MustInt()) Jobs = append(Jobs, &job) } resp.TotalCount = uint32(jsonResult.Get("total_count").MustInt())