sweep: DIRACGrid#7653 Remove dead code path in ReplicateAndRegister

DIRACGridBot · Jul 5, 2024 · 76aa85c · 76aa85c
1 parent fb61e33
commit 76aa85c
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"]: