*: address comments for 2nd round

Signed-off-by: BornChanger <[email protected]>
pingcap · Oct 27, 2023 · 613654e · 613654e
1 parent 12c9fe8
commit 613654e
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/br/pkg/aws/ebs.go b/br/pkg/aws/ebs.go
@@ -291,12 +291,10 @@ func (e *EC2Session) EnableDataFSR(meta *config.EBSBasedBRMeta, targetAZ string)
 
 	eg, _ := errgroup.WithContext(context.Background())
 
-	workerPool := utils.NewWorkerPool(uint(len(snapshotsIDsMap)), "enable snapshot FSR")
-
 	for availableZone := range snapshotsIDsMap {
 		targetAZ := availableZone
-		workerPool.ApplyOnErrorGroup(eg, func() error {
-			log.Info("enable fsr for snapshots", zap.String("available zone", availableZone))
+		eg.Go(func() error {
+			log.Info("enable fsr for snapshots", zap.String("available zone", targetAZ))
 			resp, err := e.ec2.EnableFastSnapshotRestores(&ec2.EnableFastSnapshotRestoresInput{
 				AvailabilityZones: []*string{&targetAZ},
 				SourceSnapshotIds: snapshotsIDsMap[targetAZ],
@@ -379,11 +377,9 @@ func (e *EC2Session) DisableDataFSR(snapshotsIDsMap map[string][]*string) error
 
 	eg, _ := errgroup.WithContext(context.Background())
 
-	workerPool := utils.NewWorkerPool(uint(len(snapshotsIDsMap)), "disable snapshot FSR")
-
 	for availableZone := range snapshotsIDsMap {
 		targetAZ := availableZone
-		workerPool.ApplyOnErrorGroup(eg, func() error {
+		eg.Go(func() error {
 			resp, err := e.ec2.DisableFastSnapshotRestores(&ec2.DisableFastSnapshotRestoresInput{
 				AvailabilityZones: []*string{&targetAZ},
 				SourceSnapshotIds: snapshotsIDsMap[targetAZ],