fix: incorrect name of workflow instance DAG node

This commit is contained in:
Echo009 2021-02-26 10:10:14 +08:00
parent 79b30f882d
commit cea2c0cc87

View File

@ -387,14 +387,15 @@ public class WorkflowInstanceManager {
if (!nodeInfoOpt.isPresent()) { if (!nodeInfoOpt.isPresent()) {
// 默认启用 + 不允许失败跳过 // 默认启用 + 不允许失败跳过
node.setEnable(true); node.setEnable(true)
node.setSkipWhenFailed(false); .setSkipWhenFailed(false)
node.setJobParams(jobInfo.getJobParams()); .setJobParams(jobInfo.getJobParams());
} else { } else {
WorkflowNodeInfoDO nodeInfo = nodeInfoOpt.get(); WorkflowNodeInfoDO nodeInfo = nodeInfoOpt.get();
node.setEnable(nodeInfo.getEnable()); // 使用节点别名覆盖
node.setSkipWhenFailed(nodeInfo.getSkipWhenFailed()); node.setJobName(nodeInfo.getNodeAlias())
.setEnable(nodeInfo.getEnable())
.setSkipWhenFailed(nodeInfo.getSkipWhenFailed());
// 如果节点中指定了参数信息则取节点的否则取 Job 上的 // 如果节点中指定了参数信息则取节点的否则取 Job 上的
if (!StringUtils.isBlank(nodeInfo.getNodeParams())) { if (!StringUtils.isBlank(nodeInfo.getNodeParams())) {
node.setJobParams(nodeInfo.getNodeParams()); node.setJobParams(nodeInfo.getNodeParams());