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() }