diff options
| author |  Runxi Yu | 2026-06-24 14:52:28 +0000 |
|---|---|---|
| committer | Runxi Yu | 2026-06-24 14:53:00 +0000 |
| commit | db5e5eb40d7f8652383099a2154f00158aa476c2 (patch) | |
| tree | e8c60130234137fc59505a360e804917f6c6f01e /object | |
| parent | TODO: maint, gc (diff) | |
ref/store{,/memory}: Add
Diffstat (limited to 'object')
| -rw-r--r-- | object/store/packed/internal/ingest/resolve.go | 6 |
1 files changed, 2 insertions, 4 deletions
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() |