diff --git a/internal/workerpool/pool.go b/internal/workerpool/pool.go index 8553ca25d..d59d5b009 100644 --- a/internal/workerpool/pool.go +++ b/internal/workerpool/pool.go @@ -92,7 +92,7 @@ func (p *Pool[R]) Close() { // Wait waits until all tasks have been processed. func (p *Pool[R]) Wait() { - ticker := time.NewTicker(100 * time.Millisecond) + ticker := time.NewTicker(10 * time.Millisecond) for { if !p.Processing() { return