From db5e5eb40d7f8652383099a2154f00158aa476c2 Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Wed, 24 Jun 2026 14:52:28 +0000 Subject: ref/store{,/memory}: Add --- object/store/packed/internal/ingest/resolve.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) (limited to 'object') diff --git a/object/store/packed/internal/ingest/resolve.go b/object/store/packed/internal/ingest/resolve.go index dbb1856c..7ecb58d2 100644 --- a/object/store/packed/internal/ingest/resolve.go +++ b/object/store/packed/internal/ingest/resolve.go @@ -149,13 +149,11 @@ func (res *resolver) run(workers int) error { var wg sync.WaitGroup for range workers { - wg.Add(1) - go func() { - defer wg.Done() + wg.Go(func() { res.worker() - }() + }) } wg.Wait() -- cgit v1.3.1-10-gc9f91