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: decision node missing job param

Browse Source
This commit is contained in:
Echo009 2022-01-17 17:45:39 +08:00
parent 9194641c6f
commit d7c0d12a30
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowInstanceManager.java
View File

@ -105,7 +105,9 @@ public class WorkflowInstanceManager {
// 最后检查工作流中的任务是否均处于可用状态（没有被删除）
Set<Long> allJobIds = Sets.newHashSet();
dag.getNodes().forEach(node -> {
allJobIds.add(node.getJobId());
if (node.getNodeType() == WorkflowNodeType.JOB.getCode()) {
allJobIds.add(node.getJobId());
}
// 将节点的初始状态置为等待派发
node.setStatus(InstanceStatus.WAITING_DISPATCH.getV());
});
@ -141,6 +143,7 @@ public class WorkflowInstanceManager {
node.setNodeType(workflowNodeInfo.getType())
.setJobId(workflowNodeInfo.getJobId())
.setNodeName(workflowNodeInfo.getNodeName())
.setNodeParams(workflowNodeInfo.getNodeParams())
.setEnable(workflowNodeInfo.getEnable())
.setSkipWhenFailed(workflowNodeInfo.getSkipWhenFailed());