diff --git a/lib/vdsm/virt/vm.py b/lib/vdsm/virt/vm.py index 0ffa8a7c0..4cfe89a01 100644 --- a/lib/vdsm/virt/vm.py +++ b/lib/vdsm/virt/vm.py @@ -4443,6 +4443,13 @@ def diskReplicateFinish(self, srcDisk, dstDisk): "srcDisk: %r, job: %r)", drive.name, srcDisk, blkJobInfo) + # best-effort attempt to tear down the replica + try: + self.cif.teardownVolumePath(drive.diskReplicate) + except Exception as e: + self.log.exception("Failed to teardown replica of %s: %s", + drive, e) + # Making sure that we don't have any stale information self._delDiskReplica(drive) return response.error('replicaErr')