Skip to content

Commit 67fe54b

Browse files
committed
sweepbatcher: close the quit channel when the batcher is shutting down
1 parent 1e23c76 commit 67fe54b

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

sweepbatcher/sweep_batcher.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -216,6 +216,7 @@ func (b *Batcher) Run(ctx context.Context) error {
216216
runCtx, cancel := context.WithCancel(ctx)
217217
defer func() {
218218
cancel()
219+
close(b.quit)
219220

220221
for _, batch := range b.batches {
221222
batch.Wait()

0 commit comments

Comments
 (0)