Skip to content

B
byit-myth-job
Commit ceaff428 by huangfusuper
Options

解决子工作流重跑时破坏依赖的BUG

parent 0a751937
Showing with 2 additions and 1 deletion
byit-myth-core/myth-admin-core/src/main/java/com/byit/flowservice/impl/NodeVerificationImpl.java
...@@ -79,7 +79,8 @@ public class NodeVerificationImpl implements NodeVerification { ...@@ -79,7 +79,8 @@ public class NodeVerificationImpl implements NodeVerification {
filter(jobTaskRunLog -> ( filter(jobTaskRunLog -> (
NodeRunStatusPropertyEnum.RUN_FAILURE.getCode().equals(jobTaskRunLog.getRunCode()) NodeRunStatusPropertyEnum.RUN_FAILURE.getCode().equals(jobTaskRunLog.getRunCode())
|| NodeRunStatusPropertyEnum.RE_RUN_FAILURE.getCode().equals(jobTaskRunLog.getRunCode()) || NodeRunStatusPropertyEnum.RE_RUN_FAILURE.getCode().equals(jobTaskRunLog.getRunCode())
|| NodeRunStatusPropertyEnum.PARENT_NODE_FAILED.getCode().equals(jobTaskRunLog.getRunCode()))) || NodeRunStatusPropertyEnum.PARENT_NODE_FAILED.getCode().equals(jobTaskRunLog.getRunCode())
|| NodeRunStatusPropertyEnum.KILL.getCode().equals(jobTaskRunLog.getRunCode())))
.collect(Collectors.toList()); .collect(Collectors.toList());
//当上级节点的失败个数为0时 返回true //当上级节点的失败个数为0时 返回true
if(CollectionUtil.isEmpty(errorJobLog)){ if(CollectionUtil.isEmpty(errorJobLog)){
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment