diff --git a/controllers/volumereplication_controller.go b/controllers/volumereplication_controller.go index ef5551f7..db7a7caf 100644 --- a/controllers/volumereplication_controller.go +++ b/controllers/volumereplication_controller.go @@ -237,11 +237,8 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re }, nil } } else { - replicationErr = r.markVolumeAsSecondary(instance, logger, volumeHandle, replicationHandle, parameters, secret) - // resync volume if successfully marked Secondary - if replicationErr == nil { - requeueForResync, replicationErr = r.resyncVolume(instance, logger, volumeHandle, replicationHandle, parameters, secret) - } + // resync volume as the volume is already marked Secondary + requeueForResync, replicationErr = r.resyncVolume(instance, logger, volumeHandle, replicationHandle, parameters, secret) } case replicationv1alpha1.Resync: