diff --git a/app/multitenant/sqs_control_router.go b/app/multitenant/sqs_control_router.go index 3d4360df5..8d1ab2ebc 100644 --- a/app/multitenant/sqs_control_router.go +++ b/app/multitenant/sqs_control_router.go @@ -315,6 +315,7 @@ func (pw *probeWorker) stop() { } func (pw *probeWorker) loop() { + defer pw.done.Done() for { // have we been stopped? select {