fix (rms): remove dead code path

DIRACGrid · Jun 12, 2024 · 4dbf0ce · 4dbf0ce
1 parent 2af7871
commit 4dbf0ce
Showing 1 changed file with 1 addition and 7 deletions.
diff --git 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"]: