From ae1a20845ca09031a6c71244023646b90cc5ae2f Mon Sep 17 00:00:00 2001
From: Cristiano Urban <cristiano.urban@inaf.it>
Date: Fri, 6 Dec 2024 12:02:54 +0100
Subject: [PATCH] IBM Spectrum Protect integration: minor changes, replaced
'tapePool' with 'tapeHSMFilesystem'.
Signed-off-by: Cristiano Urban <cristiano.urban@inaf.it>
---
transfer_service/retrieve_executor.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/transfer_service/retrieve_executor.py b/transfer_service/retrieve_executor.py
index 0b5378a..d141111 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()
--
GitLab