diff --git a/luigi/scheduler.py b/luigi/scheduler.py
index <HASH>..<HASH> 100644
--- a/luigi/scheduler.py
+++ b/luigi/scheduler.py
@@ -127,6 +127,10 @@ class CentralPlannerScheduler(Scheduler):
         self.update(worker)
 
         task = self._tasks.setdefault(task_id, Task(status=PENDING, deps=deps))
+
+        if task.remove is not None:
+            task.remove = None  # unmark task for removal so it isn't removed after being added
+
         if not (task.status == RUNNING and status == PENDING):
             # don't allow re-scheduling of task while it is running, it must either fail or succeed first
             task.status = status
Dont remove tasks that are added after removal mark

Change-Id: I<I>ebd<I>e<I>e<I>e4b4c<I>f4c<I>b
Reviewed-on: <URL>