From 5d7472fe8226a7656230760f64d197fde32a3c86 Mon Sep 17 00:00:00 2001 From: Preetha Appan Date: Wed, 9 Jan 2019 10:53:39 -0600 Subject: [PATCH] Remove invalid allocs --- client/client.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/client/client.go b/client/client.go index 3c41afc47..f6f537009 100644 --- a/client/client.go +++ b/client/client.go @@ -2013,7 +2013,13 @@ func (c *Client) removeAlloc(allocID string) { ar, ok := c.allocs[allocID] if !ok { - c.logger.Warn("cannot remove alloc", "alloc_id", allocID, "error", "alloc not found") + if _, ok := c.invalidAllocs[allocID]; ok { + // Removing from invalid allocs map if present + delete(c.invalidAllocs, allocID) + } else { + // Alloc is unknown, log a warning. + c.logger.Warn("cannot remove nonexistent alloc", "alloc_id", allocID, "error", "alloc not found") + } return }