Skip to content

Commit c15907b

Browse files
committed
fix (JobWrapper): correct call to getDestinationSEList
1 parent d32b8cb commit c15907b

File tree

1 file changed

+9
-6
lines changed

1 file changed

+9
-6
lines changed

src/DIRAC/WorkloadManagementSystem/JobWrapper/JobWrapper.py

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
:caption: JobWrapper options
1111
1212
"""
13+
1314
import contextlib
1415
import datetime
1516
import glob
@@ -119,14 +120,16 @@ def __init__(self, jobID: int | None = None, jobReport: JobReport | None = None)
119120
self.pilotRef = gConfig.getValue("/LocalSite/PilotReference", "Unknown")
120121
self.cpuNormalizationFactor = gConfig.getValue("/LocalSite/CPUNormalizationFactor", 0.0)
121122
self.bufferLimit = gConfig.getValue(self.section + "/BufferLimit", 10485760)
122-
self.defaultOutputSE = getDestinationSEList(
123-
gConfig.getValue("/Resources/StorageElementGroups/SE-USER", []), self.siteName
124-
)
123+
try:
124+
self.defaultOutputSE = getDestinationSEList("SE-USER", self.siteName)
125+
except RuntimeError:
126+
self.defaultOutputSE = []
125127
self.defaultCatalog = gConfig.getValue(self.section + "/DefaultCatalog", [])
126128
self.masterCatalogOnlyFlag = gConfig.getValue(self.section + "/MasterCatalogOnlyFlag", True)
127-
self.defaultFailoverSE = getDestinationSEList(
128-
gConfig.getValue("/Resources/StorageElementGroups/Tier1-Failover", []), self.siteName
129-
)
129+
try:
130+
self.defaultFailoverSE = getDestinationSEList("Tier1-Failover", self.siteName)
131+
except RuntimeError:
132+
self.defaultFailoverSE = []
130133
self.defaultOutputPath = ""
131134
self.retryUpload = gConfig.getValue(self.section + "/RetryUpload", False)
132135
self.dm = DataManager()

0 commit comments

Comments
 (0)