During Failover pull VRG from s3 only from failover cluster

Signed-off-by: Elena Gershkovich <[email protected]>

controllers/drplacementcontrol.go

@@ -535,19 +535,27 @@ func (d *DRPCInstance) checkMetroFailoverPrerequisites(curHomeCluster string) (b
 func (d *DRPCInstance) checkRegionalFailoverPrerequisites() bool {
 	d.setProgression(rmn.ProgressionWaitForStorageMaintenanceActivation)
 
-	if required, activationsRequired := requiresRegionalFailoverPrerequisites(
-		d.ctx,
-		d.reconciler.APIReader,
-		rmnutil.DRPolicyS3Profiles(d.drPolicy, d.drClusters).List(),
-		d.instance.GetName(), d.instance.GetNamespace(),
-		d.vrgs, d.instance.Spec.FailoverCluster,
-		d.reconciler.ObjStoreGetter, d.log); required {
-		for _, drCluster := range d.drClusters {
-			if drCluster.Name != d.instance.Spec.FailoverCluster {
-				continue
-			}
+	var drFailoverCluster *rmn.DRCluster
+
+	for _, drCluster := range d.drClusters {
+		if drCluster.Name != d.instance.Spec.FailoverCluster {
+			continue
+		}
+		drFailoverCluster = &drCluster
+
+		break
+	}
+
+	if drFailoverCluster != nil {
+		if required, activationsRequired := requiresRegionalFailoverPrerequisites(
+			d.ctx,
+			d.reconciler.APIReader,
+			rmnutil.DRPolicyS3Profiles(d.drPolicy, []rmn.DRCluster{*drFailoverCluster}).List(),
+			d.instance.GetName(), d.instance.GetNamespace(),
+			d.vrgs, d.instance.Spec.FailoverCluster,
+			d.reconciler.ObjStoreGetter, d.log); required {
 
-			return checkFailoverMaintenanceActivations(drCluster, activationsRequired, d.log)
+			return checkFailoverMaintenanceActivations(*drFailoverCluster, activationsRequired, d.log)
 		}
 	}