From 8aa9531a161cd92853e881d9e9385c9b8265baf1 Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Sat, 16 Jan 2021 16:09:50 +0100 Subject: [PATCH] Minor improvements. Signed-off-by: Cristiano Urban --- transfer_service/store_preprocessor.py | 3 ++- transfer_service/tape_client.py | 18 +++++++++--------- 2 files changed, 11 insertions(+), 10 deletions(-) diff --git a/transfer_service/store_preprocessor.py b/transfer_service/store_preprocessor.py index 6301cb4..c0a8a7d 100644 --- a/transfer_service/store_preprocessor.py +++ b/transfer_service/store_preprocessor.py @@ -193,6 +193,7 @@ class StorePreprocessor(TaskExecutor): self.dbConn.disconnect() def run(self): + print("Starting storage preprocessor...") self.setSourceQueueName("write_pending") self.setDestinationQueueName("write_ready") while True: @@ -203,7 +204,7 @@ class StorePreprocessor(TaskExecutor): self.prepare(self.username) self.execute() self.srcQueue.moveJobTo(self.destQueue.name()) - print("Job MOVED!") + print(f"Job {self.jobObj['jobId']} MOVED from {self.srcQueue.name()} to {self.destQueue.name()}") # Test #sp = StorePreprocessor() diff --git a/transfer_service/tape_client.py b/transfer_service/tape_client.py index 36ece40..c2826cb 100644 --- a/transfer_service/tape_client.py +++ b/transfer_service/tape_client.py @@ -75,12 +75,12 @@ class TapeClient(object): # Test -tc = TapeClient("192.168.56.101", 22, "root", "ibm") -tc.connect() -tc.copy("/home/curban/store/mydir", "/home/mydir") -tc.copy("/home/curban/store/foo2.txt", "/home/mydir/foo2.txt") -tl = tc.getTaskList() -tc.disconnect() -for i in tl: - print(i.id) - print('\n') +#tc = TapeClient("192.168.56.101", 22, "root", "ibm") +#tc.connect() +#tc.copy("/home/curban/store/mydir", "/home/mydir") +#tc.copy("/home/curban/store/foo2.txt", "/home/mydir/foo2.txt") +#tl = tc.getTaskList() +#tc.disconnect() +#for i in tl: +# print(i.id) +# print('\n') -- GitLab