This is an automated email from the ASF dual-hosted git repository.
caishunfeng 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 e2ec489042 [Fix-9610] Sub-workflow status check is limited to
SUB_PROCESS components (#9611)
e2ec489042 is described below
commit e2ec489042d59e4f63c181345da0da3d23f2a642
Author: WangJPLeo <[email protected]>
AuthorDate: Wed Apr 20 15:04:27 2022 +0800
[Fix-9610] Sub-workflow status check is limited to SUB_PROCESS components
(#9611)
* Sub-workflow status check is limited to SUB_PROCESS components
* Sub-workflow status check is limited to SUB_PROCESS components
Co-authored-by: WangJPLeo <[email protected]>
---
.../apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java | 3 +++
1 file changed, 3 insertions(+)
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 33cc6a2fbe..8fd4ce47d6 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
@@ -248,6 +248,9 @@ public class ExecutorServiceImpl extends BaseServiceImpl
implements ExecutorServ
taskDefinitions.stream()
.filter(task ->
TaskConstants.TASK_TYPE_SUB_PROCESS.equalsIgnoreCase(task.getTaskType()))
.forEach(taskDefinition ->
processDefinitionCodeSet.add(Long.valueOf(JSONUtils.getNodeString(taskDefinition.getTaskParams(),
Constants.CMD_PARAM_SUB_PROCESS_DEFINE_CODE))));
+ if (processDefinitionCodeSet.isEmpty()){
+ return true;
+ }
// check sub releaseState
List<ProcessDefinition> processDefinitions =
processDefinitionMapper.queryByCodes(processDefinitionCodeSet);
