diff --git a/client/client.go b/client/client.go index ce54fce53..081dd26f5 100644 --- a/client/client.go +++ b/client/client.go @@ -1001,10 +1001,9 @@ func (c *Client) watchAllocations(updates chan *allocUpdates) { } // Update the query index. - if resp.Index <= req.MinQueryIndex { - continue + if resp.Index > req.MinQueryIndex { + req.MinQueryIndex = resp.Index } - req.MinQueryIndex = resp.Index // Push the updates. pulled := make(map[string]*structs.Allocation, len(allocsResp.Allocs))