refactoring semaphore.NewWeighted() to errgroup.SetLimit()

Altinity · Dec 15, 2023 · 6073b94 · 6073b94
1 parent 3e60dff
commit 6073b94
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/backup/download.go b/pkg/backup/download.go
@@ -220,6 +220,7 @@ func (b *Backuper) Download(backupName string, tablePattern string, partitions [
 		}
 		log.Debugf("prepare table SHADOW concurrent semaphore with concurrency=%d len(tableMetadataAfterDownload)=%d", b.cfg.General.DownloadConcurrency, len(tableMetadataAfterDownload))
 		dataGroup, dataCtx := errgroup.WithContext(ctx)
+		dataGroup.SetLimit(int(b.cfg.General.DownloadConcurrency))
 
 		for i, tableMetadata := range tableMetadataAfterDownload {
 			if tableMetadata.MetadataOnly {