fix unnecessary warnings in allow_object_disk_streaming: true behav…

…ior during restore
Altinity · Aug 30, 2024 · 271a5b4 · 271a5b4
1 parent b7faa4a
commit 271a5b4
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/ChangeLog.md b/ChangeLog.md
@@ -1,3 +1,7 @@
+# v2.6.1 (not released yet)
+BUG FIXES
+- fix unnecessary warnings in `allow_object_disk_streaming: true` behavior during restore
+
 # v2.6.0
 IMPROVEMENTS
 - add `rbac-only` and `configs-only` parameters to `POST /backup/create` and `POST /backup/restore` API calls

diff --git a/pkg/backup/restore.go b/pkg/backup/restore.go
@@ -1398,6 +1398,8 @@ func (b *Backuper) downloadObjectDiskParts(ctx context.Context, backupName strin
 			start := time.Now()
 			downloadObjectDiskPartsWorkingGroup, downloadCtx := errgroup.WithContext(ctx)
 			downloadObjectDiskPartsWorkingGroup.SetLimit(int(b.cfg.General.ObjectDiskServerSideCopyConcurrency))
+			var isCopyFailed atomic.Bool
+			isCopyFailed.Store(false)
 			for _, part := range parts {
 				dstDiskName := diskName
 				if part.RebalancedDisk != "" {
@@ -1414,8 +1416,6 @@ func (b *Backuper) downloadObjectDiskParts(ctx context.Context, backupName strin
 						return 0, findRecursiveErr
 					}
 				}
-				var isCopyFailed atomic.Bool
-				isCopyFailed.Store(false)
 				walkErr := filepath.Walk(partPath, func(fPath string, fInfo fs.FileInfo, err error) error {
 					if err != nil {
 						return err