diff --git a/routers/repo/cloudbrain.go b/routers/repo/cloudbrain.go index daf8c277e..76c0b1b8a 100755 --- a/routers/repo/cloudbrain.go +++ b/routers/repo/cloudbrain.go @@ -356,12 +356,13 @@ func cloudBrainShow(ctx *context.Context, tpName base.TplName) { if err != nil { ctx.Data["error"] = err.Error() } - + log.Info("task.JobID=" + task.JobID) result, err := cloudbrain.GetJob(task.JobID) if err != nil { ctx.Data["error"] = err.Error() } - + accuracyJson, _ := json.Marshal(result) + log.Info(" task result=" + string(accuracyJson)) if result != nil { jobRes, _ := models.ConvertToJobResultPayload(result.Payload) jobRes.Resource.Memory = strings.ReplaceAll(jobRes.Resource.Memory, "Mi", "MB") @@ -369,8 +370,7 @@ func cloudBrainShow(ctx *context.Context, tpName base.TplName) { ctx.Data["resource_spec"] = spec taskRoles := jobRes.TaskRoles if jobRes.JobStatus.State != string(models.JobFailed) { - accuracyJson, _ := json.Marshal(taskRoles) - log.Info("taskRoles=" + string(accuracyJson)) + taskRes, _ := models.ConvertToTaskPod(taskRoles[cloudbrain.SubTaskName].(map[string]interface{})) ctx.Data["taskRes"] = taskRes task.Status = taskRes.TaskStatuses[0].State