hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-08 11:31:40 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix (#6251)

Browse source
This commit is contained in:
Stephanie Wang 2019-11-23 15:04:48 -08:00 • committed by GitHub
parent ea270495a1
commit c4fa3b3afb
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/ray/raylet/node_manager.cc
View file

@ -1969,8 +1969,10 @@ void NodeManager::HandleTaskUnblocked(
// The client is a worker. If the worker is not already unblocked and the
// unblocked task matches the one assigned to the worker, then mark the
// worker as unblocked. This returns the temporarily released resources to
// the worker.
if (worker->IsBlocked() && current_task_id == worker->GetAssignedTaskId()) {
// the worker. Workers that have been marked dead have already been cleaned
// up.
if (worker->IsBlocked() && current_task_id == worker->GetAssignedTaskId() &&
!worker->IsDead()) {
// (See design_docs/task_states.rst for the state transition diagram.)
Task task;
RAY_CHECK(local_queues_.RemoveTask(current_task_id, &task));