You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by zi...@apache.org on 2022/12/26 03:58:43 UTC
[dolphinscheduler] branch dev updated: [Improvement][api]Start the downstream workflow when it is online (#13257)
This is an automated email from the ASF dual-hosted git repository.
zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new a75a69f3ec [Improvement][api]Start the downstream workflow when it is online (#13257)
a75a69f3ec is described below
commit a75a69f3ec850236128e208351d323767fcba64a
Author: XCL <xu...@163.com>
AuthorDate: Mon Dec 26 11:58:37 2022 +0800
[Improvement][api]Start the downstream workflow when it is online (#13257)
Start the downstream workflow when it is online
---
.../apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java | 2 +-
.../org/apache/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<DependentProcessDefinition> 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}, '%')
</if>
AND a.task_type = 'DEPENDENT'
+ AND c.release_state = 1
</select>
<select id="queryTaskSubProcessDepOnProcess" resultType="org.apache.dolphinscheduler.dao.entity.TaskMainInfo">