Commit 1fc2fb23 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor change. 



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

transfer_service/task_executor.py

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

        super(TaskExecutor, self).__init__()



    def wait(self, timeout = None):

        if timeout is None:

    def wait(self, delayTime = None):

        if delayTime is None:

            time.sleep(self.execWaitTime)

        else:

            time.sleep(timeout)

            time.sleep(delayTime)



    def setSourceQueueName(self, srcQueueName):

        self.srcQueue = JobQueue(srcQueueName)