Skip to content

Commit b742998

Browse files
committed
fix(wms): download input data in the job directory
1 parent fddfcf9 commit b742998

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

src/DIRAC/WorkloadManagementSystem/Client/DownloadInputData.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -243,12 +243,13 @@ def __checkDiskSpace(self, totalSize):
243243
return S_ERROR(msg)
244244

245245
def __getDownloadDir(self, incrementCounter=True):
246+
jobIDPath = str(self.configuration.get("JobIDPath", ""))
246247
if self.inputDataDirectory == "PerFile":
247248
if incrementCounter:
248249
self.counter += 1
249-
return tempfile.mkdtemp(prefix=f"InputData_{self.counter}", dir=os.getcwd())
250+
return tempfile.mkdtemp(prefix=f"InputData_{self.counter}", dir=jobIDPath)
250251
elif self.inputDataDirectory == "CWD":
251-
return os.getcwd()
252+
return jobIDPath
252253
else:
253254
return self.inputDataDirectory
254255

0 commit comments

Comments
 (0)