diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java index 38b469a082..6192d56dfb 100644 --- a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java +++ b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java @@ -279,7 +279,7 @@ public class DagHelper { Collection startVertexs = null; if (StringUtils.isNotEmpty(parentNodeName)) { startVertexs = dag.getSubsequentNodes(parentNodeName); - // if task is CONDITION node + // if task is CONDITION node and complete then parse it TaskNode task = dag.getNode(parentNodeName); if (task.isConditionsTask() && completeTaskList.containsKey(parentNodeName)) { startVertexs = parseConditionTask(parentNodeName, task, completeTaskList);