Skip to content

Commit 6a37789

Browse files
committed
chore: codefmt
1 parent f10608f commit 6a37789

File tree

1 file changed

+12
-7
lines changed

1 file changed

+12
-7
lines changed

src/query/management/src/task/task_mgr.rs

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -436,14 +436,19 @@ impl TaskMgr {
436436
/// - `Vec<String>`: A list of dependent task names that are ready to proceed.
437437
///
438438
/// # Behavior
439-
/// 1. Retrieves all tasks that depend on the given `task_name`.
440-
/// 2. For each dependent task:
441-
/// - Check whether all its dependencies have succeeded.
439+
/// Assume:
440+
/// - `a` = given `task_name` (the completed task)
441+
/// - `b` = a task that has `a` in its `AFTER` list (i.e., depends on `a`)
442+
/// - `c` = other tasks in `b`'s `AFTER` list (other dependencies of `b`)
443+
///
444+
/// 1. Retrieves all tasks (`b`) that have `a` in their `AFTER` list.
445+
/// 2. For each `b`:
446+
/// - Check whether all its dependencies (`a` + `c`) have succeeded.
442447
/// - If all dependencies are complete:
443-
/// - Add the dependent task to the ready list.
444-
/// - Set the status of its dependencies to `not succeeded`.
445-
/// - If not all dependencies of the dependent task are complete:
446-
/// - Only mark `task_name` as succeeded.
448+
/// - Add `b` to the ready list.
449+
/// - Set the status of its dependencies (`a` + `c`) to `not succeeded`.
450+
/// - If not all dependencies of `b` are complete:
451+
/// - Only mark `a` as succeeded.
447452
#[async_backtrace::framed]
448453
#[fastrace::trace]
449454
pub async fn get_next_ready_tasks(

0 commit comments

Comments
 (0)