From a2ca38dbe28dd34d22ff625891506df14f779a23 Mon Sep 17 00:00:00 2001 From: Anton Kolesnikov Date: Thu, 28 Nov 2024 14:24:27 +0800 Subject: [PATCH] fix: compaction worker drops final status updates (#3725) --- pkg/experiment/compactor/compaction_worker.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/experiment/compactor/compaction_worker.go b/pkg/experiment/compactor/compaction_worker.go index 7522bfd85d..2e85fcd80d 100644 --- a/pkg/experiment/compactor/compaction_worker.go +++ b/pkg/experiment/compactor/compaction_worker.go @@ -123,7 +123,11 @@ func (w *Worker) running(ctx context.Context) error { for { select { case <-stopPolling: + // Now that all the threads are done, we need to + // send the final status updates. + w.poll() return + case <-ticker.C: w.poll() }