diff --git a/transfer_service/retrieve_executor.py b/transfer_service/retrieve_executor.py index 0b5378a42fd9eef374280e034df51ac9bd19c2b7..d141111db90f4a2abe79cf0435ddc547f291d899 100644 --- a/transfer_service/retrieve_executor.py +++ b/transfer_service/retrieve_executor.py @@ -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 @@ -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 @@ -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()