third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: missing job id in node when fetching workflow info

Browse Source
This commit is contained in:
Echo009 2021-03-16 16:57:43 +08:00
parent ab8c8b5f0f
commit 145d525b29
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowService.java
View File

@ -345,18 +345,14 @@ public class WorkflowService {
// 填充节点信息 // 填充节点信息
if (!CollectionUtils.isEmpty(dagInfo.getNodes())) { if (!CollectionUtils.isEmpty(dagInfo.getNodes())) {
for (PEWorkflowDAG.Node node : dagInfo.getNodes()) { for (PEWorkflowDAG.Node node : dagInfo.getNodes()) {
WorkflowNodeInfoDO nodeInfo = nodeIdNodInfoMap.get(node.getNodeId()); WorkflowNodeInfoDO nodeInfo = nodeIdNodInfoMap.get(node.getNodeId());
if (nodeInfo != null) { if (nodeInfo != null) {
node.setEnable(nodeInfo.getEnable()) node.setNodeType(nodeInfo.getType())
.setJobId(nodeInfo.getJobId())
.setEnable(nodeInfo.getEnable())
.setSkipWhenFailed(nodeInfo.getSkipWhenFailed()) .setSkipWhenFailed(nodeInfo.getSkipWhenFailed())
.setNodeName(nodeInfo.getNodeName()) .setNodeName(nodeInfo.getNodeName())
.setNodeParams(nodeInfo.getNodeParams()); .setNodeParams(nodeInfo.getNodeParams());
} else {
// 默认开启 并且 不允许失败跳过
node.setEnable(true)
.setSkipWhenFailed(false);
} }
} }
} }