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

Added minimum allowed value for the 'execWaitTime' parameter equal to 10 seconds. 



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

transfer_service/task_executor.py

+2 −0
Original line number Original line Diff line number Diff line
@@ -17,6 +17,8 @@ class TaskExecutor(Process): 
        self.maxReadyJobs = self.params.getint("max_ready_jobs")

        self.maxReadyJobs = self.params.getint("max_ready_jobs")

        self.maxTerminatedJobs = self.params.getint("max_terminated_jobs")

        self.maxTerminatedJobs = self.params.getint("max_terminated_jobs")

        self.execWaitTime = self.params.getint("exec_wait_time")

        self.execWaitTime = self.params.getint("exec_wait_time")

        if self.execWaitTime < 10:

            self.execWaitTime = 10

        self.srcQueue = None

        self.srcQueue = None

        self.destQueue = None

        self.destQueue = None

        super(TaskExecutor, self).__init__()

        super(TaskExecutor, self).__init__()