|
|
@@ -1105,7 +1105,15 @@ func handleNoDurationTask(cloudBrains []*models.Cloudbrain) { |
|
|
} |
|
|
} |
|
|
jobRes, _ := models.ConvertToJobResultPayload(result.Payload) |
|
|
jobRes, _ := models.ConvertToJobResultPayload(result.Payload) |
|
|
taskRoles := jobRes.TaskRoles |
|
|
taskRoles := jobRes.TaskRoles |
|
|
|
|
|
if len(taskRoles) == 0 { |
|
|
|
|
|
updateDefaultDuration(task) |
|
|
|
|
|
continue |
|
|
|
|
|
} |
|
|
taskRes, _ := models.ConvertToTaskPod(taskRoles[cloudbrain.SubTaskName].(map[string]interface{})) |
|
|
taskRes, _ := models.ConvertToTaskPod(taskRoles[cloudbrain.SubTaskName].(map[string]interface{})) |
|
|
|
|
|
if len(taskRes.TaskStatuses) == 0 { |
|
|
|
|
|
updateDefaultDuration(task) |
|
|
|
|
|
continue |
|
|
|
|
|
} |
|
|
task.Status = taskRes.TaskStatuses[0].State |
|
|
task.Status = taskRes.TaskStatuses[0].State |
|
|
startTime := taskRes.TaskStatuses[0].StartAt.Unix() |
|
|
startTime := taskRes.TaskStatuses[0].StartAt.Unix() |
|
|
endTime := taskRes.TaskStatuses[0].FinishedAt.Unix() |
|
|
endTime := taskRes.TaskStatuses[0].FinishedAt.Unix() |
|
|
|