fix(restore): reset bandwidth limit for restore

scylladb · Sep 2, 2024 · 01cb187 · 01cb187
1 parent 23610c5
commit 01cb187
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/service/restore/tables_worker.go b/pkg/service/restore/tables_worker.go
@@ -208,6 +208,12 @@ func (w *tablesWorker) stageRestoreData(ctx context.Context) error {
 	}
 	hosts := hostsS.List()
 
+	for _, h := range hosts {
+		if err := w.client.RcloneSetBandwidthLimit(ctx, h, 0); err != nil {
+			return errors.Wrapf(err, "reset bandwidth limit on %s", h)
+		}
+	}
+
 	if w.target.UnpinAgentCPU {
 		defer func() {
 			for _, h := range hosts {