diff --git a/controllers/replicationdestination.go b/controllers/replicationdestination.go index 40d7cae..a0e07d1 100644 --- a/controllers/replicationdestination.go +++ b/controllers/replicationdestination.go @@ -58,7 +58,8 @@ func (r *VolumeSnapshotRestoreReconciler) CreateReplicationDestination(log logr. return r.buildReplicationDestination(repDestination, &vsr, &resticSecret) }) - if err != nil { + if err != nil && !k8serrors.IsAlreadyExists(err){ + // don't error out if create errors due to replicationDestination already exists return false, err } diff --git a/controllers/replicationsource.go b/controllers/replicationsource.go index 9012bb7..916b097 100644 --- a/controllers/replicationsource.go +++ b/controllers/replicationsource.go @@ -50,7 +50,8 @@ func (r *VolumeSnapshotBackupReconciler) CreateReplicationSource(log logr.Logger return r.buildReplicationSource(repSource, &vsb, &clonedPVC) }) - if err != nil { + if err != nil && !k8serrors.IsAlreadyExists(err){ + // don't error out if create errors due to replicationSource already exists return false, err }