mirror of
https://github.com/wassname/ray.git
synced 2026-08-08 11:25:28 +08:00
mark all remaining placeable tasks pending with task dependency manager (#2528)
This commit is contained in:
committed by
Robert Nishihara
parent
981d9818c1
commit
85b8b2a395
@@ -750,6 +750,14 @@ void NodeManager::ScheduleTasks() {
|
||||
EnqueuePlaceableTask(t);
|
||||
}
|
||||
}
|
||||
|
||||
// All remaining placeable tasks should be registered with the task dependency
|
||||
// manager. TaskDependencyManager::TaskPending() is assumed to be idempotent.
|
||||
// TODO(atumanov): evaluate performance implications of registering all new tasks on
|
||||
// submission vs. registering remaining queued placeable tasks here.
|
||||
for (const auto &task : local_queues_.GetPlaceableTasks()) {
|
||||
task_dependency_manager_.TaskPending(task);
|
||||
}
|
||||
}
|
||||
|
||||
void NodeManager::TreatTaskAsFailed(const TaskSpecification &spec) {
|
||||
|
||||
Reference in New Issue
Block a user