Loading transfer_service/retrieve_executor.py +3 −3 Original line number Diff line number Diff line Loading @@ -81,7 +81,7 @@ class RetrieveExecutor(TaskExecutor): params["user"], params["pkey_file_path"], self.logger) self.tapePool = None self.tapeHSMFilesystem = None self.storageType = None self.jobObj = None self.jobId = None Loading Loading @@ -125,7 +125,7 @@ class RetrieveExecutor(TaskExecutor): #self.storageType = self.dbConn.getOSPath(self.nodeList[0])["storageType"] fileInfo = self.dbConn.getOSPath(self.nodeList[0]) self.storageType = fileInfo["storageType"] self.tapePool = fileInfo["tapePool"] self.tapeHSMFilesystem = fileInfo["tapeHSMFilesystem"] except Exception: self.logger.exception("FATAL: unable to obtain the storage type.") return False Loading Loading @@ -321,7 +321,7 @@ class RetrieveExecutor(TaskExecutor): # is 'cold' if self.storageType == "cold": self.tapeClient.connect() self.tapeClient.migrate([ f["fullPath"] for f in blockFileList if f["fileSize"] > 0 ], self.tapePool, self.jobId) self.tapeClient.migrate([ f["fullPath"] for f in blockFileList if f["fileSize"] > 0 ], self.tapeHSMFilesystem, self.jobId) self.tapeClient.disconnect() blockFileList.clear() Loading Loading
transfer_service/retrieve_executor.py +3 −3 Original line number Diff line number Diff line Loading @@ -81,7 +81,7 @@ class RetrieveExecutor(TaskExecutor): params["user"], params["pkey_file_path"], self.logger) self.tapePool = None self.tapeHSMFilesystem = None self.storageType = None self.jobObj = None self.jobId = None Loading Loading @@ -125,7 +125,7 @@ class RetrieveExecutor(TaskExecutor): #self.storageType = self.dbConn.getOSPath(self.nodeList[0])["storageType"] fileInfo = self.dbConn.getOSPath(self.nodeList[0]) self.storageType = fileInfo["storageType"] self.tapePool = fileInfo["tapePool"] self.tapeHSMFilesystem = fileInfo["tapeHSMFilesystem"] except Exception: self.logger.exception("FATAL: unable to obtain the storage type.") return False Loading Loading @@ -321,7 +321,7 @@ class RetrieveExecutor(TaskExecutor): # is 'cold' if self.storageType == "cold": self.tapeClient.connect() self.tapeClient.migrate([ f["fullPath"] for f in blockFileList if f["fileSize"] > 0 ], self.tapePool, self.jobId) self.tapeClient.migrate([ f["fullPath"] for f in blockFileList if f["fileSize"] > 0 ], self.tapeHSMFilesystem, self.jobId) self.tapeClient.disconnect() blockFileList.clear() Loading