From fa3981d167466e1b8c1b4c962767d945ff007fb1 Mon Sep 17 00:00:00 2001 From: Echo009 Date: Fri, 19 Feb 2021 11:21:39 +0800 Subject: [PATCH] =?UTF-8?q?docs:=20=E6=94=B9=E5=8A=A8=E8=BE=83=E5=A4=A7?= =?UTF-8?q?=E7=9A=84=E7=B1=BB=E6=96=87=E4=BB=B6=E6=B7=BB=E5=8A=A0=20@autho?= =?UTF-8?q?r=20=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../powerjob/server/common/utils/WorkflowDAGUtils.java | 1 + .../kfcfans/powerjob/server/service/DispatchService.java | 1 + .../server/service/workflow/WorkflowInstanceManager.java | 5 +++-- .../server/service/workflow/WorkflowInstanceService.java | 1 + 4 files changed, 6 insertions(+), 2 deletions(-) diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/utils/WorkflowDAGUtils.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/utils/WorkflowDAGUtils.java index ab20feb4..d70287d8 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/utils/WorkflowDAGUtils.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/utils/WorkflowDAGUtils.java @@ -17,6 +17,7 @@ import java.util.Set; * DAG 工具类 * * @author tjq + * @author Echo009 * @since 2020/5/26 */ public class WorkflowDAGUtils { diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java index 81179b95..04e82603 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java @@ -33,6 +33,7 @@ import static com.github.kfcfans.powerjob.common.InstanceStatus.*; * 派送服务(将任务从Server派发到Worker) * * @author tjq + * @author Echo009 * @since 2020/4/5 */ @Slf4j diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowInstanceManager.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowInstanceManager.java index 5edf6281..20c8f6f9 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowInstanceManager.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowInstanceManager.java @@ -35,6 +35,7 @@ import static com.github.kfcfans.powerjob.server.common.utils.WorkflowDAGUtils.i * 管理运行中的工作流实例 * * @author tjq + * @author Echo009 * @since 2020/5/26 */ @Slf4j @@ -417,10 +418,10 @@ public class WorkflowInstanceManager { } - private boolean isFinish(PEWorkflowDAG dag){ + private boolean isFinish(PEWorkflowDAG dag) { for (PEWorkflowDAG.Node node : dag.getNodes()) { if (InstanceStatus.GENERALIZED_RUNNING_STATUS.contains(node.getStatus())) { - return false; + return false; } } return true; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowInstanceService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowInstanceService.java index 9cbe2ae8..d3e77387 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowInstanceService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowInstanceService.java @@ -29,6 +29,7 @@ import static com.github.kfcfans.powerjob.server.common.utils.WorkflowDAGUtils.i * 工作流实例服务 * * @author tjq + * @author Echo009 * @since 2020/5/31 */ @Slf4j