|
|
@@ -65,12 +65,15 @@ func GetCloudbrainTask(ctx *context.APIContext) { |
|
|
|
return |
|
|
|
} |
|
|
|
|
|
|
|
taskRoles := result.TaskRoles |
|
|
|
taskRes, _ := models.ConvertToTaskPod(taskRoles[cloudbrain.SubTaskName].(map[string]interface{})) |
|
|
|
job.Status = result.JobStatus.State |
|
|
|
if result.JobStatus.State != string(models.JobWaiting) && result.JobStatus.State != string(models.JobFailed) { |
|
|
|
taskRoles := result.TaskRoles |
|
|
|
taskRes, _ := models.ConvertToTaskPod(taskRoles[cloudbrain.SubTaskName].(map[string]interface{})) |
|
|
|
|
|
|
|
job.ContainerIp = taskRes.TaskStatuses[0].ContainerIP |
|
|
|
job.ContainerID = taskRes.TaskStatuses[0].ContainerID |
|
|
|
job.Status = taskRes.TaskStatuses[0].State |
|
|
|
job.ContainerIp = taskRes.TaskStatuses[0].ContainerIP |
|
|
|
job.ContainerID = taskRes.TaskStatuses[0].ContainerID |
|
|
|
job.Status = taskRes.TaskStatuses[0].State |
|
|
|
} |
|
|
|
|
|
|
|
if result.JobStatus.State != string(models.JobWaiting) { |
|
|
|
err = models.UpdateJob(job) |
|
|
|