diff --git a/pkg/health/queuedProbeWorker.go b/pkg/health/queuedProbeWorker.go index 13aced6c0..c4159fda4 100644 --- a/pkg/health/queuedProbeWorker.go +++ b/pkg/health/queuedProbeWorker.go @@ -79,6 +79,7 @@ func (q *QueuedProbeWorker) dequeue(ctx context.Context) (HealthRequest, bool) { q.mux.Unlock() reqChn <- req + return } }()