From 145d525b29a7b98f4e593db7e0a4a690649a9863 Mon Sep 17 00:00:00 2001 From: Echo009 Date: Tue, 16 Mar 2021 16:57:43 +0800 Subject: [PATCH] fix: missing job id in node when fetching workflow info --- .../powerjob/server/core/workflow/WorkflowService.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowService.java b/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowService.java index 57f05347..78bcdedc 100644 --- a/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowService.java +++ b/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowService.java @@ -345,18 +345,14 @@ public class WorkflowService { // 填充节点信息 if (!CollectionUtils.isEmpty(dagInfo.getNodes())) { for (PEWorkflowDAG.Node node : dagInfo.getNodes()) { - WorkflowNodeInfoDO nodeInfo = nodeIdNodInfoMap.get(node.getNodeId()); if (nodeInfo != null) { - node.setEnable(nodeInfo.getEnable()) + node.setNodeType(nodeInfo.getType()) + .setJobId(nodeInfo.getJobId()) + .setEnable(nodeInfo.getEnable()) .setSkipWhenFailed(nodeInfo.getSkipWhenFailed()) .setNodeName(nodeInfo.getNodeName()) .setNodeParams(nodeInfo.getNodeParams()); - - } else { - // 默认开启 并且 不允许失败跳过 - node.setEnable(true) - .setSkipWhenFailed(false); } } }