diff --git a/client/allocrunner/alloc_runner.go b/client/allocrunner/alloc_runner.go index 01accbde3..7cc2802d8 100644 --- a/client/allocrunner/alloc_runner.go +++ b/client/allocrunner/alloc_runner.go @@ -652,7 +652,7 @@ func (ar *allocRunner) handleAllocUpdates() { case update := <-ar.allocUpdatedCh: ar.handleAllocUpdate(update) case <-ar.waitCh: - break + return } } }