diff --git a/cmd/gitea-cli/cmd/upload.go b/cmd/gitea-cli/cmd/upload.go index d60677a62e..8fffd032b3 100644 --- a/cmd/gitea-cli/cmd/upload.go +++ b/cmd/gitea-cli/cmd/upload.go @@ -367,9 +367,7 @@ func uploadChunks(ctx context.Context, server, token string, session *UploadSess // Start workers for range parallel { - wg.Add(1) - go func() { //nolint:modernize // Using separate error channel for first-error semantics - defer wg.Done() + wg.Go(func() { for job := range jobs { err := uploadChunk(server, token, session.ID, job.number, job.data) if err != nil { @@ -378,7 +376,7 @@ func uploadChunks(ctx context.Context, server, token string, session *UploadSess } tracker.Add(int64(len(job.data))) } - }() + }) } // Progress display diff --git a/sdk/go/upload.go b/sdk/go/upload.go index 62e5e86461..d371ed65f1 100644 --- a/sdk/go/upload.go +++ b/sdk/go/upload.go @@ -173,9 +173,7 @@ func (cu *ChunkedUpload) uploadChunks(ctx context.Context, reader io.ReaderAt) e // Start workers for range cu.options.Parallel { - wg.Add(1) - go func() { //nolint:modernize // Using separate error channel for first-error semantics - defer wg.Done() + wg.Go(func() { for j := range jobs { if err := cu.uploadChunk(ctx, j.number, j.data); err != nil { errors <- err @@ -184,7 +182,7 @@ func (cu *ChunkedUpload) uploadChunks(ctx context.Context, reader io.ReaderAt) e atomic.AddInt64(&cu.bytesWritten, int64(len(j.data))) cu.reportProgress() } - }() + }) } // Queue chunks