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

Added 'max_clean_jobs' parameter. 



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

transfer_service/config/vos_ts.conf.sample

+2 −0
Original line number Diff line number Diff line
@@ -69,6 +69,8 @@ max_pending_jobs = 32 
max_ready_jobs = 4

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

max_terminated_jobs = 8

; maximum number of jobs within the 'clean' ('read' only) queue, default is 8

max_clean_jobs = 8

; minimum time interval in seconds between two consecutive checks on 

; job queues, default is 15 s, minimum allowed is 10 s

exec_wait_time = 15

transfer_service/task_executor.py

+1 −0
Original line number Diff line number Diff line
@@ -16,6 +16,7 @@ class TaskExecutor(Process): 
        self.maxPendingJobs = params.getint("max_pending_jobs")

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

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

        self.maxCleanJobs = params.getint("max_clean_jobs")

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

        if self.execWaitTime < 10:

            self.execWaitTime = 10