Browse Source

change forbidden task process

pull/2/head
lenboo 6 years ago
parent
commit
79b05a4405
  1. 10
      escheduler-dao/src/main/java/cn/escheduler/dao/utils/DagHelper.java

10
escheduler-dao/src/main/java/cn/escheduler/dao/utils/DagHelper.java

@ -250,10 +250,10 @@ public class DagHelper {
startVertexs = dag.getBeginNode(); startVertexs = dag.getBeginNode();
} }
Collection<String> tmpStartVertexs = new ArrayList<>(); List<String> tmpStartVertexs = new ArrayList<>();
tmpStartVertexs.addAll(startVertexs); tmpStartVertexs.addAll(startVertexs);
for(String start : tmpStartVertexs){ for(String start : startVertexs){
TaskNode startNode = dag.getNode(start); TaskNode startNode = dag.getNode(start);
if(!startNode.isForbidden()){ if(!startNode.isForbidden()){
continue; continue;
@ -262,13 +262,13 @@ public class DagHelper {
for(String post : postNodes){ for(String post : postNodes){
if(checkForbiddenPostCanSubmit(post, dag)){ if(checkForbiddenPostCanSubmit(post, dag)){
startVertexs.add(post); tmpStartVertexs.add(post);
} }
} }
startVertexs.remove(start); tmpStartVertexs.remove(start);
} }
return startVertexs; return tmpStartVertexs;
} }
/** /**

Loading…
Cancel
Save