Merge pull request #678 from flyysoul/fix_publishTaskInfo

fix publishTaskInfo (#676)
DTStack · Aug 5, 2022 · ac7d49a · ac7d49a
2 parents daa32dc + ac2114c
commit ac7d49a
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...elop/src/main/java/com/dtstack/taier/develop/service/develop/impl/DevelopTaskService.java b/...elop/src/main/java/com/dtstack/taier/develop/service/develop/impl/DevelopTaskService.java
@@ -455,10 +455,10 @@ public TaskCheckResultVO publishTaskInfo(Task task, Long userId) {
         TaskCheckResultVO checkResultVO = new TaskCheckResultVO();
         checkResultVO.setErrorSign(PublishTaskStatusEnum.NOMAL.getType());
 
-        if (EScheduleJobType.WORK_FLOW.getType().equals(task.getTaskType())) {
+        // 发布任务中所有的依赖关系
+        List<ScheduleTaskTaskShade> allTaskTaskList = new ArrayList<>();
 
-            // 发布任务中所有的依赖关系
-            List<ScheduleTaskTaskShade> allTaskTaskList = new ArrayList<>();
+        if (EScheduleJobType.WORK_FLOW.getType().equals(task.getTaskType())) {
 
             final List<Task> subTasks = getFlowWorkSubTasks(task.getId());
             subTasks.add(task);
@@ -499,7 +499,7 @@ public TaskCheckResultVO publishTaskInfo(Task task, Long userId) {
         } else {
             try {
                 // 构建要发布的任务列表
-                ScheduleTaskShade scheduleTasks = buildScheduleTaskShadeDTO(task, null);
+                ScheduleTaskShade scheduleTasks = buildScheduleTaskShadeDTO(task, allTaskTaskList);
 
                 // 提交任务参数信息并保存任务记录和更新任务状态
                 sendTaskStartTrigger(task.getId(), userId, scheduleTasks);