File tree Expand file tree Collapse file tree 2 files changed +21
-3
lines changed
WorkloadManagementSystem/Agent Expand file tree Collapse file tree 2 files changed +21
-3
lines changed Original file line number Diff line number Diff line change 3
3
# Author : A.T.
4
4
########################################################################
5
5
6
- """ The Pool Computing Element is an "inner" CE (meaning it's used by a jobAgent inside a pilot)
6
+ """The Pool Computing Element is an "inner" CE (meaning it's used by a jobAgent inside a pilot)
7
7
8
- It's used running several jobs simultaneously in separate processes, managed by a ProcessPool
8
+ It's used running several jobs simultaneously in separate processes, managed by a ProcessPool.
9
+
10
+ **Configuration Parameters**
11
+
12
+ LocalCEType:
13
+ Configuration for the PoolCE submission can be done via the CE configuration such as::
14
+
15
+ LocalCEType = Pool
16
+
17
+ The Pool Computing Element is specific: it embeds an additional "inner" CE
18
+ (`InProcess` by default, `Sudo`, `Singularity`). The "inner" CE can be specified such as::
19
+
20
+ LocalCEType = Pool/Singularity
21
+
22
+ NumberOfProcessors:
23
+ Maximum number of processors that can be used to compute jobs.
24
+
25
+ **Code Documentation**
9
26
"""
10
27
import os
11
28
import concurrent .futures
Original file line number Diff line number Diff line change @@ -135,7 +135,8 @@ def _initializeComputingElement(self, localCE):
135
135
self .log .warn ("Can't instantiate a CE" , ceInstance ["Message" ])
136
136
return ceInstance
137
137
self .computingElement = ceInstance ["Value" ]
138
- self .computingElement .ceParameters ["InnerCESubmissionType" ] = self .innerCESubmissionType
138
+ self .computingElement .setParameters ({"InnerCESubmissionType" : self .innerCESubmissionType })
139
+
139
140
return S_OK ()
140
141
141
142
#############################################################################
You can’t perform that action at this time.
0 commit comments