Merge pull request DIRACGrid#7720 from DIRACGridBot/cherry-pick-2-71d…

…ef4ba8-integration [sweep:integration] Remove dead code path in ReplicateAndRegister
DIRACGridBot · Jul 5, 2024 · dfcae1d · dfcae1d
2 parents fb61e33 + 76aa85c
commit dfcae1d
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
@@ -599,13 +599,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
@@ -617,6 +610,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"]: