Commit 8e635a83 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor changes. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent ce35578b

transfer_service/store_executor.py

+1 −1
Original line number Diff line number Diff line
@@ -60,7 +60,7 @@ class StoreExecutor(TaskExecutor): 
        



    def run(self):

        print("Starting storage executor...")

        print("Starting store executor...")

        self.setSourceQueueName("write_ready")

        self.setDestinationQueueName("write_terminated")

        while True:

transfer_service/store_preprocessor.py

+1 −1
Original line number Diff line number Diff line
@@ -196,7 +196,7 @@ class StorePreprocessor(TaskExecutor): 
        self.dbConn.disconnect()



    def run(self):

        print("Starting storage preprocessor...")

        print("Starting store preprocessor...")

        self.setSourceQueueName("write_pending")

        self.setDestinationQueueName("write_ready")

        while True: