|
|
@@ -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 |
|
|
|