diff --git a/pkg/local_object_storage/shard/gc.go b/pkg/local_object_storage/shard/gc.go index fc39a9b0b..8363ebf96 100644 --- a/pkg/local_object_storage/shard/gc.go +++ b/pkg/local_object_storage/shard/gc.go @@ -123,7 +123,9 @@ func (gc *gc) listenEvents() { v.prevGroup.Add(len(v.handlers)) - for _, h := range v.handlers { + for i := range v.handlers { + h := v.handlers[i] + err := gc.workerPool.Submit(func() { h(ctx, event) v.prevGroup.Done()