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 <[email protected]>
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">