diff --git a/manager/orchestrator/taskreaper/task_reaper.go b/manager/orchestrator/taskreaper/task_reaper.go index 8ef2b4f7b0..a66a01da70 100644 --- a/manager/orchestrator/taskreaper/task_reaper.go +++ b/manager/orchestrator/taskreaper/task_reaper.go @@ -177,6 +177,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 }