From eadb656d0d437767c7622955bf3f202c012dc91f Mon Sep 17 00:00:00 2001
From: Cristiano Urban <cristiano.urban@inaf.it>
Date: Wed, 23 Apr 2025 14:45:52 +0200
Subject: [PATCH] Reduced 'execWaitTime' minimum value.
Signed-off-by: Cristiano Urban <cristiano.urban@inaf.it>
---
transfer_service/config/vos_ts.conf.sample | 4 ++--
transfer_service/task_executor.py | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/transfer_service/config/vos_ts.conf.sample b/transfer_service/config/vos_ts.conf.sample
index 14e6c4e..40a821e 100644
--- a/transfer_service/config/vos_ts.conf.sample
+++ b/transfer_service/config/vos_ts.conf.sample
@@ -80,8 +80,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
+; job queues, default is 10 s, minimum allowed is 5 s
+exec_wait_time = 10
[transfer]
; split data to be retrieved in blocks of a given size
diff --git a/transfer_service/task_executor.py b/transfer_service/task_executor.py
index 3b4f048..3baee03 100644
--- a/transfer_service/task_executor.py
+++ b/transfer_service/task_executor.py
@@ -23,8 +23,8 @@ class TaskExecutor(Process):
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
+ if self.execWaitTime < 5:
+ self.execWaitTime = 5
self.srcQueue = None
self.destQueue = None
super(TaskExecutor, self).__init__()
--
GitLab