Skip to content
Snippets Groups Projects
Commit 8aa9531a authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor improvements.

parent 57d76986
No related branches found
No related tags found
No related merge requests found
...@@ -193,6 +193,7 @@ class StorePreprocessor(TaskExecutor): ...@@ -193,6 +193,7 @@ class StorePreprocessor(TaskExecutor):
self.dbConn.disconnect() self.dbConn.disconnect()
def run(self): def run(self):
print("Starting storage preprocessor...")
self.setSourceQueueName("write_pending") self.setSourceQueueName("write_pending")
self.setDestinationQueueName("write_ready") self.setDestinationQueueName("write_ready")
while True: while True:
...@@ -203,7 +204,7 @@ class StorePreprocessor(TaskExecutor): ...@@ -203,7 +204,7 @@ class StorePreprocessor(TaskExecutor):
self.prepare(self.username) self.prepare(self.username)
self.execute() self.execute()
self.srcQueue.moveJobTo(self.destQueue.name()) 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 # Test
#sp = StorePreprocessor() #sp = StorePreprocessor()
......
...@@ -75,12 +75,12 @@ class TapeClient(object): ...@@ -75,12 +75,12 @@ class TapeClient(object):
# Test # Test
tc = TapeClient("192.168.56.101", 22, "root", "ibm") #tc = TapeClient("192.168.56.101", 22, "root", "ibm")
tc.connect() #tc.connect()
tc.copy("/home/curban/store/mydir", "/home/mydir") #tc.copy("/home/curban/store/mydir", "/home/mydir")
tc.copy("/home/curban/store/foo2.txt", "/home/mydir/foo2.txt") #tc.copy("/home/curban/store/foo2.txt", "/home/mydir/foo2.txt")
tl = tc.getTaskList() #tl = tc.getTaskList()
tc.disconnect() #tc.disconnect()
for i in tl: #for i in tl:
print(i.id) # print(i.id)
print('\n') # print('\n')
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment