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