wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-08-03 13:10:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

Remove stray change (#6247)

Browse Source
This commit is contained in:
Eric Liang
2019-11-23 00:07:45 -08:00
committed by GitHub
parent 94d37eee28
commit ea270495a1
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/raylet/node_manager.cc
+6 -8
View File
@@ -1949,14 +1949,12 @@ void NodeManager::HandleTaskBlocked(const std::shared_ptr<LocalClientConnection>
// Subscribe to the objects required by the task. These objects will be
// fetched and/or reconstructed as necessary, until the objects become local
// or are unsubscribed.
if (!required_object_ids.empty()) {
if (ray_get) {
task_dependency_manager_.SubscribeGetDependencies(current_task_id,
required_object_ids);
} else {
task_dependency_manager_.SubscribeWaitDependencies(worker->WorkerId(),
required_object_ids);
}
if (ray_get) {
task_dependency_manager_.SubscribeGetDependencies(current_task_id,
required_object_ids);
} else {
task_dependency_manager_.SubscribeWaitDependencies(worker->WorkerId(),
required_object_ids);
}
}