kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-06 10:25:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

Remove invalid allocs

Browse Source
This commit is contained in:
Preetha Appan
2019-01-09 10:53:39 -06:00
parent 80919bf713
commit 5d7472fe82
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
client/client.go
View File

@@ -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
}