From a75a69f3ec850236128e208351d323767fcba64a Mon Sep 17 00:00:00 2001 From: XCL Date: Mon, 26 Dec 2022 11:58:37 +0800 Subject: [PATCH] [Improvement][api]Start the downstream workflow when it is online (#13257) Start the downstream workflow when it is online --- .../dolphinscheduler/api/service/impl/ExecutorServiceImpl.java | 2 +- .../dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java index f03a97881f..6f9a99e11d 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java @@ -1142,7 +1142,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ } /** - * get complement dependent process definition list + * get complement dependent online process definition list */ private List getComplementDependentDefinitionList(long processDefinitionCode, CycleEnum processDefinitionCycle, diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml index 2689b6d50f..9eac0d0a12 100644 --- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml +++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml @@ -161,6 +161,7 @@ AND a.task_params LIKE concat('%', #{code}, '%') AND a.task_type = 'DEPENDENT' + AND c.release_state = 1