|
|
|
@@ -225,8 +225,11 @@ func TimerHandleModelSafetyTestTask() { |
|
|
|
} |
|
|
|
|
|
|
|
func queryTaskStatusFromGrampus(task *models.Cloudbrain) { |
|
|
|
log.Info("The task not finished,name=" + task.DisplayJobName) |
|
|
|
if task.DeletedAt.IsZero() { //normal record |
|
|
|
result, err := grampus.GetJob(task.JobID) |
|
|
|
resultJson, _ := json.Marshal(result) |
|
|
|
log.Info("resultJson=" + string(resultJson)) |
|
|
|
if err != nil { |
|
|
|
log.Error("GetJob failed:" + err.Error()) |
|
|
|
return |
|
|
|
|