Merge pull request #10905 from germanfgv/logCollectOVerrides

Use siteLocalConfig in logCollect jobs to specify output site
dmwm · Dec 2, 2021 · ba8e8c3 · ba8e8c3
2 parents 83e6cf2 + a1469fb
commit ba8e8c3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/python/WMCore/WMSpec/Steps/Executors/LogCollect.py b/src/python/WMCore/WMSpec/Steps/Executors/LogCollect.py
@@ -22,6 +22,7 @@
 from WMCore.WMRuntime.Tools.Scram import Scram, getSingleScramArch, isCMSSWSupported
 from WMCore.WMSpec.Steps.Executor import Executor
 from WMCore.WMSpec.Steps.WMExecutionFailure import WMExecutionFailure
+from WMCore.Storage.SiteLocalConfig import loadSiteLocalConfig
 
 
 class LogCollect(Executor):
@@ -65,6 +66,9 @@ def execute(self, emulator=None):
         overrides = {}
         if hasattr(self.step, 'override'):
             overrides = self.step.override.dictionary_()
+            if overrides.get('logRedirectSiteLocalConfig', None):
+                siteCfg = loadSiteLocalConfig()
+                overrides.update(siteCfg.localStageOut)
 
         # Set wait to over an hour
         waitTime = overrides.get('waitTime', 3600 + (self.step.retryDelay * self.step.retryCount))