wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-27 17:31:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Qing Wang
2021-01-19 01:24:01 +08:00
parent 516eb77080
commit e3fc7729ac
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/raylet/node_manager.cc
+9
View File
@@ -2146,6 +2146,15 @@ void NodeManager::ForwardTaskOrResubmit(const Task &task, const NodeID &node_man
void NodeManager::ForwardTask(
const Task &task, const NodeID &node_id,
const std::function<void(const ray::Status &, const Task &)> &on_error) {
const auto &spec = task.GetTaskSpecification();
auto task_id = spec.TaskId();
if (worker_pool_.HasPendingWorkerForTask(spec.GetLanguage(), task_id)) {
// There is a worker being starting for this task,
// so we shouldn't forward this task to another node.
on_error(ray::Status::Invalid("Already has pending worker for this task."), task);
return;
}
// This method spillbacks lease requests to other nodes.
// TODO(sang): Modify method names.
RAY_CHECK(task.OnSpillback() != nullptr);