diff --git a/internal/syncutil/limit.go b/internal/syncutil/limit.go index d0a3d88a..f2caabf7 100644 --- a/internal/syncutil/limit.go +++ b/internal/syncutil/limit.go @@ -81,7 +81,6 @@ func Go[T any](ctx context.Context, limiter *semaphore.Weighted, fn GoFunc[T], i eg.Go(func(t T) func() error { return func() error { defer region.End() - // cancel the gorountine before the next goroutine is created err := fn(egCtx, region, t) if err != nil { egErr.CompareAndSwap(nil, err)