|
|
|
@@ -328,11 +328,11 @@ public class ExperimentInsServiceImpl implements ExperimentInsService { |
|
|
|
experimentIns.setNodesStatus(nodeStatusJson); |
|
|
|
|
|
|
|
//终止态为终止不改 |
|
|
|
if (!StringUtils.equals(experimentIns.getStatus(), "Terminated")) { |
|
|
|
experimentIns.setStatus(StringUtils.isNotEmpty((String) status.get("phase")) ? (String) status.get("phase") : "Pending"); |
|
|
|
if (!StringUtils.equals(experimentIns.getStatus(), Constant.Terminated)) { |
|
|
|
experimentIns.setStatus(StringUtils.isNotEmpty((String) status.get("phase")) ? (String) status.get("phase") : Constant.Pending); |
|
|
|
} |
|
|
|
if (StringUtils.equals(experimentIns.getStatus(), Constant.Error)) { |
|
|
|
experimentIns.setStatus("Failed"); |
|
|
|
experimentIns.setStatus(Constant.Failed); |
|
|
|
} |
|
|
|
|
|
|
|
return experimentIns; |
|
|
|
@@ -661,7 +661,7 @@ public class ExperimentInsServiceImpl implements ExperimentInsService { |
|
|
|
// 定义终止态的列表,例如 "Succeeded", "Failed" 等 |
|
|
|
String status = ins.getStatus(); |
|
|
|
boolean flag = true; |
|
|
|
List<String> terminatedStates = Arrays.asList("Succeeded", "Failed"); |
|
|
|
List<String> terminatedStates = Arrays.asList("Succeeded", Constant.Failed); |
|
|
|
flag = terminatedStates.contains(status); |
|
|
|
if (StringUtils.equals(status, "Terminated")) { |
|
|
|
//如果跟node_status里面不一样,就要去更新node_status的信息 |
|
|
|
|