File tree Expand file tree Collapse file tree 1 file changed +8
-8
lines changed
src/query/management/src/task Expand file tree Collapse file tree 1 file changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -424,15 +424,15 @@ impl TaskMgr {
424424 /// - `Vec<String>`: A list of dependent task names that are ready to proceed.
425425 ///
426426 /// # Behavior
427- /// 1. Retrieves all tasks that must be executed *before* the given `task_name`.
428- /// 2. For each such task, find the tasks that depend on it (`after` tasks).
429- /// 3. For each `after` task:
430- /// - If all its dependencies (excluding the current task) are succeeded :
431- /// - Mark that task as **not succeeded**.
432- /// - Also mark the current task as succeeded.
433- /// - Record it as ready for further processing.
427+ /// 1. Retrieves all tasks that the given `task_name` is a dependency of (i.e., tasks that depend on `task_name`) .
428+ /// 2. For each such dependent task:
429+ /// - Check whether all its dependencies (excluding `task_name`) have succeeded.
430+ /// - If so :
431+ /// - Mark that task as **not succeeded** to trigger reevaluation or blocking .
432+ /// - Mark `task_name` as succeeded.
433+ /// - Add the task to the ready list for further processing.
434434 /// - Otherwise:
435- /// - Still mark the current task as succeeded.
435+ /// - Still mark `task_name` as succeeded.
436436 #[ async_backtrace:: framed]
437437 #[ fastrace:: trace]
438438 pub async fn get_next_ready_tasks (
You can’t perform that action at this time.
0 commit comments