File tree Expand file tree Collapse file tree 1 file changed +6
-5
lines changed
Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -254,10 +254,9 @@ def getInputDataCatalog(
254254
255255 self .log .verbose (localSEList )
256256
257- if not inputDataPolicy :
258- inputDataPolicy = Operations ().getValue ("InputDataPolicy/InputDataModule" )
259- if not inputDataPolicy :
260- return self ._errorReport ("Could not retrieve /DIRAC/Operations/InputDataPolicy/InputDataModule for VO" )
257+ inputDataModule = Operations ().getValue ("InputDataPolicy/InputDataModule" )
258+ if not inputDataModule :
259+ return self ._errorReport ("Could not retrieve /DIRAC/Operations/InputDataPolicy/InputDataModule for VO" )
261260
262261 self .log .info (f"Attempting to resolve data for { siteName } " )
263262 self .log .verbose ("%s" % ("\n " .join (lfns )))
@@ -286,11 +285,13 @@ def getInputDataCatalog(
286285
287286 self .log .verbose (configDict )
288287 argumentsDict = {"FileCatalog" : resolvedData , "Configuration" : configDict , "InputData" : lfns }
288+ if inputDataPolicy :
289+ argumentsDict ["Job" ] = {"InputDataPolicy" : inputDataPolicy }
289290 if ignoreMissing :
290291 argumentsDict ["IgnoreMissing" ] = True
291292 self .log .verbose (argumentsDict )
292293
293- result = self .objectLoader .loadObject (inputDataPolicy )
294+ result = self .objectLoader .loadObject (inputDataModule )
294295 if not result ["OK" ]:
295296 return result
296297 module = result ["Value" ](argumentsDict )
You can’t perform that action at this time.
0 commit comments