diff --git a/transfer_service/store_preprocessor.py b/transfer_service/store_preprocessor.py index 6301cb49523c7253743d42878452a890daed5adb..c0a8a7d8375f5a0d4d4e2f2e2a59a3f9ca856ac1 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 36ece40c43360306f2d71129e2c40c5e4f7f00fd..c2826cbcc566caf0bf044a8776a3d6509f50bc21 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')