From ea270495a1c670929afb13850304afb01803fa54 Mon Sep 17 00:00:00 2001 From: Eric Liang Date: Sat, 23 Nov 2019 00:07:45 -0800 Subject: [PATCH] Remove stray change (#6247) --- src/ray/raylet/node_manager.cc | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/src/ray/raylet/node_manager.cc b/src/ray/raylet/node_manager.cc index 67f84aca5..13fd38ea6 100644 --- a/src/ray/raylet/node_manager.cc +++ b/src/ray/raylet/node_manager.cc @@ -1949,14 +1949,12 @@ void NodeManager::HandleTaskBlocked(const std::shared_ptr // 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); } }