Loading transfer_service/retrieve_preprocessor.py +9 −4 Original line number Diff line number Diff line Loading @@ -29,6 +29,11 @@ class RetrievePreprocessor(TaskExecutor): else: self.nodeList = self.dbConn.getVOSpacePathList(vospacePath) self.jobObj.jobInfo["nodeList"] = self.nodeList if os.path.exists("nl.txt"): os.remove("nl.txt") nl = open("nl.txt", 'w') nl.write(json.dumps(self.nodeList, indent = 4)) nl.close() def cleanup(self): self.nodeList.clear() Loading Loading
transfer_service/retrieve_preprocessor.py +9 −4 Original line number Diff line number Diff line Loading @@ -29,6 +29,11 @@ class RetrievePreprocessor(TaskExecutor): else: self.nodeList = self.dbConn.getVOSpacePathList(vospacePath) self.jobObj.jobInfo["nodeList"] = self.nodeList if os.path.exists("nl.txt"): os.remove("nl.txt") nl = open("nl.txt", 'w') nl.write(json.dumps(self.nodeList, indent = 4)) nl.close() def cleanup(self): self.nodeList.clear() Loading