diff --git a/src/ray/core_worker/task_manager.cc b/src/ray/core_worker/task_manager.cc index be9c6858f..cb70483bc 100644 --- a/src/ray/core_worker/task_manager.cc +++ b/src/ray/core_worker/task_manager.cc @@ -460,11 +460,8 @@ std::vector TaskManager::GetPendingChildrenTasks( const TaskID &parent_task_id) const { std::vector ret_vec; absl::MutexLock lock(&mu_); - RAY_LOG(ERROR) << " calling get children tasks"; - RAY_LOG(ERROR) << "NUMBER OF PENDING TASKS: " << num_pending_tasks_; for (auto it : submissible_tasks_) { - RAY_LOG(ERROR) << "Getting tasks!! " << it.second.spec.TaskId(); - if (it.second.pending and it.second.spec.ParentTaskId() == parent_task_id) { + if ((it.second.pending) && (it.second.spec.ParentTaskId() == parent_task_id)) { ret_vec.push_back(it.first); } }