diff --git a/pkg/service/restore/worker.go b/pkg/service/restore/worker.go index 4237eee6dc..1b931dc3c7 100644 --- a/pkg/service/restore/worker.go +++ b/pkg/service/restore/worker.go @@ -121,13 +121,11 @@ func (w *worker) initTarget(ctx context.Context, properties json.RawMessage) err remotePath = l.RemotePath("") locationStatus = status ) - // In order to improve restore schema stability, we ignore location's dc assignment - if t.RestoreTables { - if l.DC == "" { - w.logger.Info(ctx, "No datacenter specified for location - using all nodes for this location", "location", l) - } else { - locationStatus = status.Datacenter([]string{l.DC}) - } + + if l.DC == "" { + w.logger.Info(ctx, "No datacenter specified for location - using all nodes for this location", "location", l) + } else { + locationStatus = status.Datacenter([]string{l.DC}) } nodes, err := w.client.GetNodesWithLocationAccess(ctx, locationStatus, remotePath)