|
|
|
@@ -380,7 +380,7 @@ func queryTaskStatusFromCloudbrain(job *models.Cloudbrain) { |
|
|
|
taskRes, _ := models.ConvertToTaskPod(taskRoles[cloudbrain.SubTaskName].(map[string]interface{})) |
|
|
|
job.Status = taskRes.TaskStatuses[0].State |
|
|
|
} |
|
|
|
|
|
|
|
log.Info("cloud brain one job status=" + job.Status) |
|
|
|
if result.JobStatus.State != string(models.JobSucceeded) { |
|
|
|
err = models.UpdateJob(job) |
|
|
|
if err != nil { |
|
|
|
@@ -428,6 +428,7 @@ func queryTaskStatusFromModelSafetyTestServer(job *models.Cloudbrain) { |
|
|
|
} |
|
|
|
|
|
|
|
func sendGPUInferenceResultToTest(job *models.Cloudbrain) { |
|
|
|
log.Info("send sendGPUInferenceResultToTest") |
|
|
|
datasetname := job.DatasetName |
|
|
|
datasetnames := strings.Split(datasetname, ";") |
|
|
|
indicator := job.LabelName |
|
|
|
|