From d4eb8e33034b7caf58c4093f299240b6a1f07fcf Mon Sep 17 00:00:00 2001 From: Echo009 Date: Thu, 10 Feb 2022 15:14:31 +0800 Subject: [PATCH] fix: the problem of incorrect sub-workflow state --- .../server/core/workflow/WorkflowInstanceManager.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowInstanceManager.java b/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowInstanceManager.java index 8ec6b337..5beac8a3 100644 --- a/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowInstanceManager.java +++ b/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/workflow/WorkflowInstanceManager.java @@ -238,12 +238,10 @@ public class WorkflowInstanceManager { } if (readyNodes.isEmpty()) { // 没有就绪的节点（所有节点都被禁用） - wfInstanceInfo.setStatus(WorkflowInstanceStatus.SUCCEED.getV()); - wfInstanceInfo.setResult(SystemInstanceResult.NO_ENABLED_NODES); wfInstanceInfo.setFinishedTime(System.currentTimeMillis()); wfInstanceInfo.setDag(JSON.toJSONString(dag)); log.warn("[Workflow-{}|{}] workflowInstance({}) needn't running ", wfInfo.getId(), wfInstanceId, wfInstanceInfo); - workflowInstanceInfoRepository.saveAndFlush(wfInstanceInfo); + handleWfInstanceFinalStatus(wfInstanceInfo, SystemInstanceResult.NO_ENABLED_NODES, WorkflowInstanceStatus.SUCCEED); return; } // 需要更新工作流实例状态