File tree Expand file tree Collapse file tree 1 file changed +8
-9
lines changed
src/query/management/src/task Expand file tree Collapse file tree 1 file changed +8
-9
lines changed Original file line number Diff line number Diff line change @@ -424,15 +424,14 @@ 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 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
- /// - Otherwise:
435
- /// - Still mark `task_name` as succeeded.
427
+ /// 1. Retrieves all tasks that depend on the given `task_name`.
428
+ /// 2. For each dependent task:
429
+ /// - Check whether all its dependencies have succeeded.
430
+ /// - If all dependencies are complete:
431
+ /// - Add the dependent task to the ready list.
432
+ /// - Set the status of its dependencies to `not succeeded`.
433
+ /// - If not all dependencies of the dependent task are complete:
434
+ /// - Only mark `task_name` as succeeded.
436
435
#[ async_backtrace:: framed]
437
436
#[ fastrace:: trace]
438
437
pub async fn get_next_ready_tasks (
You can’t perform that action at this time.
0 commit comments