optimit code

weibocom · Oct 30, 2024 · 734bf66 · 734bf66
1 parent ea1f168
commit 734bf66
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/...ympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java b/...ympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java
@@ -123,10 +123,8 @@ private boolean isStreamTaskReadyToRun(Set<TaskInfo> readyToRunTasks, TaskInfo d
         boolean streamDependencyStarted = false;
         boolean blockDependencyFinished = false;
         if (dependencyOutputType == TaskInputOutputType.STREAM) {
-            // 1. 任意依赖的流式输出任务开始执行或者准备被执行
             streamDependencyStarted = dependency.getTaskStatus() != TaskStatus.NOT_STARTED || readyToRunTasks.contains(dependency);
         } else {
-            // 2. 任意依赖的非流式输出任务执行完成（包括关键路径模式下关键路径执行完成）
             blockDependencyFinished = isTaskSuccessOrSkip(dependency, isTaskKeyMode);
         }
         return streamDependencyStarted || blockDependencyFinished;