Commit d22dd3d3 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Added 'max_terminated_jobs' parameter. 



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

transfer_service/task_executor.py

+1 −0
Original line number Diff line number Diff line
@@ -13,6 +13,7 @@ class TaskExecutor(Process): 
        self.params = config.loadSection("scheduling")

        self.maxPendingJobs = self.params.getint("max_pending_jobs")

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

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

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

        self.srcQueue = None

        self.destQueue = None

transfer_service/vos_ts.conf

+2 −0
Original line number Diff line number Diff line
@@ -58,6 +58,8 @@ max_dir_size = 100 
max_pending_jobs = 32

; maximum number of jobs within a 'ready' queue, default is 4

max_ready_jobs = 4

; maximum number of jobs within a 'terminated' queue, default is 8

max_terminated_jobs = 8

; minimum time interval in seconds between two consecutive checks on 

; job queues (do NOT set to zero), default is 15 s

exec_wait_time = 15