diff --git a/internal/controller/drplacementcontrolvolsync.go b/internal/controller/drplacementcontrolvolsync.go index efd05ed65..df6b4eeb8 100644 --- a/internal/controller/drplacementcontrolvolsync.go +++ b/internal/controller/drplacementcontrolvolsync.go @@ -30,6 +30,10 @@ func (d *DRPCInstance) EnsureSecondaryReplicationSetup(srcCluster string) error return fmt.Errorf("failed to find source VRG in cluster %s. VRGs %v", srcCluster, d.vrgs) } + return d.EnsureVolSyncReplicationSetup(srcCluster) +} + +func (d *DRPCInstance) EnsureVolSyncReplicationSetup(srcCluster string) error { vsRepNeeded, err := d.IsVolSyncReplicationRequired(srcCluster) if err != nil { return err