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

[xray] Fix bug where driver task ID is assumed to be nil (#2725)

Browse Source 
## What do these changes do?

#2362 left a bug where it assumed that the driver task ID was nil. This fixes the bug to check the `SchedulingQueue` for any driver task IDs instead.
This commit is contained in:
Stephanie Wang
2018-08-23 14:44:47 -07:00
committed by Robert Nishihara
parent 344a83f327
commit 1b3de31ff1
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/raylet/node_manager.cc
+2 -4
View File
@@ -1278,10 +1278,8 @@ void NodeManager::HandleObjectMissing(const ObjectID &object_id) {
// Check that remaining tasks that could not be transitioned are running
// workers or drivers, now blocked in a get.
local_queues_.FilterState(waiting_task_id_set, TaskState::RUNNING);
if (!waiting_task_id_set.empty()) {
RAY_CHECK(waiting_task_id_set.size() == 1);
RAY_CHECK(waiting_task_id_set.begin()->is_nil());
}
local_queues_.FilterState(waiting_task_id_set, TaskState::DRIVER);
RAY_CHECK(waiting_task_id_set.empty());
}
}