Skip to content

Commit a2ca38d

Browse files
authored
fix: compaction worker drops final status updates (#3725)
1 parent 7861b51 commit a2ca38d

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

pkg/experiment/compactor/compaction_worker.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,11 @@ func (w *Worker) running(ctx context.Context) error {
123123
for {
124124
select {
125125
case <-stopPolling:
126+
// Now that all the threads are done, we need to
127+
// send the final status updates.
128+
w.poll()
126129
return
130+
127131
case <-ticker.C:
128132
w.poll()
129133
}

0 commit comments

Comments
 (0)