mirror of
https://github.com/kemko/nomad.git
synced 2026-01-01 16:05:42 +03:00
be8575a8a2
* Move group into a separate helper module for reuse * Add shutdownCh to worker The shutdown channel is used to signal that worker has stopped. * Make server shutdown block on workers' shutdownCh * Fix waiting for eval broker state change blocking indefinitely There was a race condition in the GenericNotifier between the Run and WaitForChange functions, where WaitForChange blocks trying to write to a full unsubscribeCh, but the Run function never reads from the unsubscribeCh as it has already stopped. This commit fixes it by unblocking if the notifier has been stopped. * Bound the amount of time server shutdown waits on worker completion * Fix lostcancel linter error * Fix worker test using unexpected worker constructor * Add changelog --------- Co-authored-by: Marvin Chin <marvinchin@users.noreply.github.com>
4 lines
129 B
Plaintext
4 lines
129 B
Plaintext
```release-note:bug
|
|
server: Fix server not waiting for workers to submit nacks for dequeued evaluations before shutting down
|
|
```
|