Skip to content

Commit 2f599d8

Browse files
committed
[Improvement-17057][Master]Check if the WorkflowGrapth is a dag at constructor(#17057)
1 parent 56ac7e7 commit 2f599d8

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/graph/WorkflowGraph.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,8 @@
1717

1818
package org.apache.dolphinscheduler.server.master.engine.graph;
1919

20+
import static com.google.common.base.Preconditions.checkNotNull;
21+
2022
import org.apache.dolphinscheduler.dao.entity.TaskDefinition;
2123
import org.apache.dolphinscheduler.dao.entity.WorkflowTaskRelation;
2224

@@ -31,8 +33,6 @@
3133
import java.util.function.Function;
3234
import java.util.stream.Collectors;
3335

34-
import static com.google.common.base.Preconditions.checkNotNull;
35-
3636
public class WorkflowGraph implements IWorkflowGraph {
3737

3838
private final Map<Long, TaskDefinition> taskDefinitionCodeMap;

dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/engine/graph/WorkflowGraphCheckIfDAGTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
package org.apache.dolphinscheduler.server.master.engine.graph;
1919

20-
2120
import org.apache.dolphinscheduler.dao.entity.TaskDefinition;
2221
import org.apache.dolphinscheduler.dao.entity.WorkflowTaskRelation;
2322

0 commit comments

Comments
 (0)