Loading client/vos_storage +1 −1 Original line number Diff line number Diff line Loading @@ -48,7 +48,7 @@ class VOSStorage(RedisRPCClient): tapePoolList = storageResponse["tapePoolList"] while tapePool not in tapePoolList: print("\nSelect one of the available tape pools:") print("\n" + tabulate(tapePoolList, headers = ["tape_pool"], tablefmt = "pretty") + "\n") print("\n" + tabulate([ [t] for t in tapePoolList ], headers = ["tape_pool"], tablefmt = "pretty") + "\n") try: tapePool = input("Please, insert a tape pool: ") except ValueError: Loading transfer_service/storage_rpc_server.py +3 −1 Original line number Diff line number Diff line Loading @@ -59,6 +59,7 @@ class StorageRPCServer(RedisRPCServer): storageType = requestBody["storageType"] storageBasePath = requestBody["basePath"] storageHostname = requestBody["hostname"] tapePool = requestBody["tapePool"] if not os.path.exists(storageBasePath): errorMsg = "Base path doesn't exist." self.logger.error(errorMsg) Loading @@ -70,7 +71,8 @@ class StorageRPCServer(RedisRPCServer): result = self.dbConn.insertStorage(storageType, storageBasePath, storageHostname, self.vospaceUserBasePath) self.vospaceUserBasePath, tapePool) except Exception: errorMsg = "Database error." self.logger.exception(errorMsg) Loading Loading
client/vos_storage +1 −1 Original line number Diff line number Diff line Loading @@ -48,7 +48,7 @@ class VOSStorage(RedisRPCClient): tapePoolList = storageResponse["tapePoolList"] while tapePool not in tapePoolList: print("\nSelect one of the available tape pools:") print("\n" + tabulate(tapePoolList, headers = ["tape_pool"], tablefmt = "pretty") + "\n") print("\n" + tabulate([ [t] for t in tapePoolList ], headers = ["tape_pool"], tablefmt = "pretty") + "\n") try: tapePool = input("Please, insert a tape pool: ") except ValueError: Loading
transfer_service/storage_rpc_server.py +3 −1 Original line number Diff line number Diff line Loading @@ -59,6 +59,7 @@ class StorageRPCServer(RedisRPCServer): storageType = requestBody["storageType"] storageBasePath = requestBody["basePath"] storageHostname = requestBody["hostname"] tapePool = requestBody["tapePool"] if not os.path.exists(storageBasePath): errorMsg = "Base path doesn't exist." self.logger.error(errorMsg) Loading @@ -70,7 +71,8 @@ class StorageRPCServer(RedisRPCServer): result = self.dbConn.insertStorage(storageType, storageBasePath, storageHostname, self.vospaceUserBasePath) self.vospaceUserBasePath, tapePool) except Exception: errorMsg = "Database error." self.logger.exception(errorMsg) Loading