Browse Source

[Improvement][api]Start the downstream workflow when it is online (#13257)

Start the downstream workflow when it is online
3.2.0-release
XCL 2 years ago committed by GitHub
parent
commit
a75a69f3ec
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
  2. 1
      dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml

2
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, private List<DependentProcessDefinition> getComplementDependentDefinitionList(long processDefinitionCode,
CycleEnum processDefinitionCycle, CycleEnum processDefinitionCycle,

1
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_params LIKE concat('%', #{code}, '%')
</if> </if>
AND a.task_type = 'DEPENDENT' AND a.task_type = 'DEPENDENT'
AND c.release_state = 1
</select> </select>
<select id="queryTaskSubProcessDepOnProcess" resultType="org.apache.dolphinscheduler.dao.entity.TaskMainInfo"> <select id="queryTaskSubProcessDepOnProcess" resultType="org.apache.dolphinscheduler.dao.entity.TaskMainInfo">

Loading…
Cancel
Save