[core] Fix losing task state when giving up forward task. (#7525)

* fix NodeManager::Forward task bug on error

* fix lint

* revert spillback task forward
This commit is contained in:
micafan
2020-03-13 11:49:44 +08:00
committed by GitHub
parent 768d0b3b3f
commit cc91ed57dc
+1
View File
@@ -2962,6 +2962,7 @@ void NodeManager::ForwardTask(
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;
}