Skip to content

B
byit-myth-job
Commit 917f201f by guominglei
Options

去除重跑时不依赖的节点

parent 6fbd5c6f
Showing with 3 additions and 3 deletions
byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowServiceImpl.java
...@@ -523,9 +523,9 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -523,9 +523,9 @@ public class ApiFlowServiceImpl implements ApiFlowService {
runNodeIdSet.add(nodeId); runNodeIdSet.add(nodeId);
}); });
while(!queue.isEmpty()){ while(!queue.isEmpty()){
subNodeIdList = nodeDependencyMapper.findSubNodeList(queue.poll()); List<Integer> innerSubNodeIdList = nodeDependencyMapper.findSubNodeList(queue.poll());
if (subNodeIdList != null && subNodeIdList.size() > 0){ if (innerSubNodeIdList != null && innerSubNodeIdList.size() > 0){
subNodeIdList.forEach(nodeId->{ innerSubNodeIdList.forEach(nodeId->{
queue.offer(nodeId); queue.offer(nodeId);
runNodeIdSet.add(nodeId); runNodeIdSet.add(nodeId);
}); });
......
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