|
|
|
@@ -47,7 +47,7 @@ public class ExperimentInstanceStatusTask { |
|
|
|
experimentIns.setStatus("Failed"); |
|
|
|
} |
|
|
|
//运行成功的实验实例记录指标数值 |
|
|
|
if (Constant.Succeeded.equals(experimentIns.getStatus())) { |
|
|
|
// if (Constant.Succeeded.equals(experimentIns.getStatus())) { |
|
|
|
Map<String, Object> metricRecord = JacksonUtil.parseJSONStr2Map(experimentIns.getMetricRecord()); |
|
|
|
List<Map<String, Object>> trainMetricRecords = (List<Map<String, Object>>) metricRecord.get("train"); |
|
|
|
List<Map<String, Object>> evaluateMetricRecords = (List<Map<String, Object>>) metricRecord.get("evaluate"); |
|
|
|
@@ -92,7 +92,7 @@ public class ExperimentInstanceStatusTask { |
|
|
|
metricValue.put("train", trainMetricValues); |
|
|
|
metricValue.put("evaluate", evaluateMetricValues); |
|
|
|
experimentIns.setMetricValue(JsonUtils.mapToJson(metricValue)); |
|
|
|
} |
|
|
|
// } |
|
|
|
experimentIns.setUpdateTime(new Date()); |
|
|
|
// 线程安全的添加操作 |
|
|
|
synchronized (experimentIds) { |
|
|
|
|