Skip to content

Commit f3e3e50

Browse files
committed
Improve some comments
1 parent 716a985 commit f3e3e50

2 files changed

Lines changed: 5 additions & 5 deletions

File tree

src/coordinator/prepare_static_plan.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,9 @@ use rand::Rng;
1919
use std::sync::Arc;
2020

2121
/// Prepares the distributed plan for execution, which implies:
22-
/// 1. Perform some worker assignation, choosing randomly from the given URLs and assigning one
23-
/// URL per task.
22+
/// 1. Perform some worker URL assignation, choosing either:
23+
/// - The URLs set by the user with [crate::TaskEstimator::route_tasks].
24+
/// - Randomly otherwise
2425
/// 2. Sending the sliced subplans to the assigned URLs. For each URL assigned to a task, a
2526
/// network call feeding the subplan is necessary.
2627
/// 3. In each network boundary, set the input plan to `None`. That way, network boundaries

src/coordinator/task_spawner.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -262,9 +262,8 @@ impl<'a> CoordinatorToWorkerTaskSpawner<'a> {
262262
});
263263
}
264264

265-
/// Instantiates and returns the task that based on the different local [WorkUnitFeedExec]
266-
/// nodes, sends their inner [WorkUnitFeeds] over the network to their remote counterparts.
267-
/// The returned task is just a future that does nothing unless polled.
265+
/// Launches the task that based on the different local [WorkUnitFeedExec] nodes, sends their
266+
/// inner [WorkUnitFeeds] over the network to their remote counterparts.
268267
///
269268
/// Once this function is called, all the [WorkUnitFeedExec]s feeds will be consumed.
270269
pub(super) fn work_unit_feed_task(

0 commit comments

Comments
 (0)