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 {
424
424
/// - `Vec<String>`: A list of dependent task names that are ready to proceed.
425
425
///
426
426
/// # 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.
434
434
/// - Otherwise:
435
- /// - Still mark the current task as succeeded.
435
+ /// - Still mark `task_name` as succeeded.
436
436
#[ async_backtrace:: framed]
437
437
#[ fastrace:: trace]
438
438
pub async fn get_next_ready_tasks (
You can’t perform that action at this time.
0 commit comments