From cc91ed57dc6c7e8ed06f1a12b4be6f8464808af8 Mon Sep 17 00:00:00 2001
From: micafan <550435771@qq.com>
Date: Fri, 13 Mar 2020 11:49:44 +0800
Subject: [PATCH] [core] Fix losing task state when giving up forward task.
 (#7525)

* fix NodeManager::Forward task bug on error

* fix lint

* revert spillback task forward
---
 src/ray/raylet/node_manager.cc | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/ray/raylet/node_manager.cc b/src/ray/raylet/node_manager.cc
index 8f933d015..d5c92f63b 100644
--- a/src/ray/raylet/node_manager.cc
+++ b/src/ray/raylet/node_manager.cc
@@ -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;
   }