From bee2318f4f02f117f522d10cbffd338415956f4c Mon Sep 17 00:00:00 2001 From: Anshul Pundir Date: Tue, 19 Jun 2018 11:25:27 -0700 Subject: [PATCH] [orchestrator/task reaper] Clean up tasks in dirty list for which the service has been deleted. Signed-off-by: Anshul Pundir (cherry picked from commit 592e8eddfa43ec5fbd6e34da5ad6890dfa9313fb) Signed-off-by: Sebastiaan van Stijn --- manager/orchestrator/taskreaper/task_reaper.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/manager/orchestrator/taskreaper/task_reaper.go b/manager/orchestrator/taskreaper/task_reaper.go index 1c93b77fbe..3bdd8b4220 100644 --- a/manager/orchestrator/taskreaper/task_reaper.go +++ b/manager/orchestrator/taskreaper/task_reaper.go @@ -188,6 +188,9 @@ func (tr *TaskReaper) tick() { for dirty := range tr.dirty { service := store.GetService(tx, dirty.ServiceID) if service == nil { + // If the service can't be found, assume that it was deleted + // and remove the slot from the dirty list. + delete(tr.dirty, dirty) continue }