Commit 168b7958 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Allow to change the time to wait directly. 



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

transfer_service/task_executor.py

+5 −2
Original line number Diff line number Diff line
@@ -29,8 +29,11 @@ class TaskExecutor(Process): 
        self.destQueue = None

        super(TaskExecutor, self).__init__()



    def wait(self):

    def wait(self, timeout = None):

        if timeout is None:

            time.sleep(self.execWaitTime)

        else:

            time.sleep(timeout)



    def setSourceQueueName(self, srcQueueName):

        self.srcQueue = JobQueue(srcQueueName)