Revert "fix(restore): improve restore schema for Scylla 5.4.0"

This reverts commit 3a10977.

pkg/service/restore/worker.go

@@ -121,14 +121,11 @@ func (w *worker) initTarget(ctx context.Context, properties json.RawMessage) err
 			remotePath     = l.RemotePath("")
 			locationStatus = status
 		)
-		// Restore schema has to download ALL schema to ALL nodes,
-		// so it can't filter used nodes by location datacenter.
-		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})
-			}
+		// In case location does not have specified dc, use nodes from all dcs
+		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)
@@ -138,24 +135,15 @@ func (w *worker) initTarget(ctx context.Context, properties json.RawMessage) err
 			}
 			return errors.Wrapf(err, "location %s is not accessible", l)
 		}
+		if len(nodes) == 0 {
+			return fmt.Errorf("no nodes with location %s access", l)
+		}
+
 		var hosts []string
 		for _, n := range nodes {
 			hosts = append(hosts, n.Addr)
 		}
 
-		if len(hosts) == 0 {
-			return fmt.Errorf("no nodes with location %s access", l)
-		}
-		if t.RestoreSchema && len(hosts) != len(status) {
-			noAccess := strset.New()
-			for _, n := range status {
-				noAccess.Add(n.Addr)
-			}
-			noAccess.Remove(hosts...)
-			return fmt.Errorf("restoring schema requires all nodes to have access to all locations."+
-				" Nodes %s don't have access to location %s", noAccess.String(), l.String())
-		}
-
 		w.logger.Info(ctx, "Found hosts with location access", "location", l, "hosts", hosts)
 		locationHosts[l] = hosts
 	}