Skip to content

Commit 689e7d4

Browse files
committed
feat (RMS): change the REA defaults for higher perf
1 parent 1ba455b commit 689e7d4

File tree

2 files changed

+14
-12
lines changed

2 files changed

+14
-12
lines changed

src/DIRAC/RequestManagementSystem/Agent/RequestExecutingAgent.py

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -48,21 +48,23 @@
4848
# # agent name
4949
AGENT_NAME = "RequestManagement/RequestExecutingAgent"
5050
# # requests/cycle
51-
REQUESTSPERCYCLE = 100
51+
REQUESTSPERCYCLE = 300
5252
# # minimal nb of subprocess running
53-
MINPROCESS = 20
53+
MINPROCESS = 50
5454
# # maximal nb of subprocess executed same time
55-
MAXPROCESS = 20
55+
MAXPROCESS = 50
5656
# # ProcessPool queue size
57-
QUEUESIZE = 20
57+
QUEUESIZE = 100
5858
# # file timeout
5959
FILETIMEOUT = 300
6060
# # operation timeout
6161
OPERATIONTIMEOUT = 300
6262
# # ProcessPool finalization timeout
6363
POOLTIMEOUT = 900
6464
# # ProcessPool sleep time
65-
POOLSLEEP = 5
65+
POOLSLEEP = 1
66+
# # Fetch multiple requests at once from the DB. Otherwise, one by one
67+
BULKREQUEST = 300
6668

6769

6870
class AgentConfigError(Exception):
@@ -108,7 +110,7 @@ def __init__(self, *args, **kwargs):
108110
self.__poolSleep = POOLSLEEP
109111
self.__requestClient = None
110112
# Size of the bulk if use of getRequests. If 0, use getRequest
111-
self.__bulkRequest = 0
113+
self.__bulkRequest = BULKREQUEST
112114
self.__rmsMonitoring = False
113115

114116
def processPool(self):

src/DIRAC/RequestManagementSystem/ConfigTemplate.cfg

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -44,19 +44,19 @@ Agents
4444
{
4545
PollingTime = 60
4646
# number of Requests to execute per cycle
47-
RequestsPerCycle = 100
47+
RequestsPerCycle = 300
4848
# minimum number of workers process in the ProcessPool
49-
MinProcess = 20
49+
MinProcess = 50
5050
# maximum number of workers process in the ProcessPool; recommended to set it to the same value as MinProcess
51-
MaxProcess = 20
51+
MaxProcess = 50
5252
# queue depth of the ProcessPool
53-
ProcessPoolQueueSize = 20
53+
ProcessPoolQueueSize = 100
5454
# timeout for the ProcessPool finalization
5555
ProcessPoolTimeout = 900
5656
# sleep time before retrying to get a free slot in the ProcessPool
57-
ProcessPoolSleep = 5
57+
ProcessPoolSleep = 1
5858
# If a positive integer n is given, we fetch n requests at once from the DB. Otherwise, one by one
59-
BulkRequest = 0
59+
BulkRequest = 300
6060
OperationHandlers
6161
{
6262
ForwardDISET

0 commit comments

Comments
 (0)