diff --git a/rill-flow-dag/olympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java b/rill-flow-dag/olympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java
index c19e2788..0af5236a 100644
--- a/rill-flow-dag/olympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java
+++ b/rill-flow-dag/olympicene-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;