From 4dbf0ce2bcb23fb0825cb66dffbf8b92939251c8 Mon Sep 17 00:00:00 2001 From: Christophe Haen Date: Thu, 6 Jun 2024 17:01:25 +0200 Subject: [PATCH] fix (rms): remove dead code path --- .../Agent/RequestOperations/ReplicateAndRegister.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/src/DIRAC/DataManagementSystem/Agent/RequestOperations/ReplicateAndRegister.py b/src/DIRAC/DataManagementSystem/Agent/RequestOperations/ReplicateAndRegister.py index cf0b98f3718..71af8c5562d 100644 --- a/src/DIRAC/DataManagementSystem/Agent/RequestOperations/ReplicateAndRegister.py +++ b/src/DIRAC/DataManagementSystem/Agent/RequestOperations/ReplicateAndRegister.py @@ -605,13 +605,6 @@ def dmTransfer(self, fromFTS=False): # All source SEs are banned, delay execution by 1 hour delayExecution = 60 continue - # # get the first one in the list - if sourceSE not in validReplicas: - if sourceSE: - err = "File not at specified source" - errors[err] += 1 - self.log.warn(f"{lfn} is not at specified sourceSE {sourceSE}, changed to {validReplicas[0]}") - sourceSE = validReplicas[0] # # loop over targetSE catalogs = self.operation.Catalog @@ -623,6 +616,7 @@ def dmTransfer(self, fromFTS=False): if targetSE in validReplicas: self.log.warn(f"Request to replicate {lfn} to an existing location: {targetSE}") continue + sourceSE = self.operation.SourceSE if self.operation.SourceSE else None res = self.dm.replicateAndRegister(lfn, targetSE, sourceSE=sourceSE, catalog=catalogs) if res["OK"]: if lfn in res["Value"]["Successful"]: