@@ -183,9 +183,9 @@ def getQueryParams(self):
183
183
## For 'jobids', 'sitewhitelist' and 'siteblacklist', attr_value is either a list of strings or None.
184
184
if attr_value is not None :
185
185
configreq [attr_name ] = attr_value
186
- for attr_name in ['maxjobruntime' , 'maxmemory' , 'numcores' , ' priority' ]:
186
+ for attr_name in ['maxjobruntime' , 'maxmemory' , 'priority' ]:
187
187
attr_value = getattr (self .options , attr_name )
188
- ## For 'maxjobruntime', 'maxmemory', 'numcores', and 'priority', attr_value is either an integer or None.
188
+ ## For 'maxjobruntime', 'maxmemory', and 'priority', attr_value is either an integer or None.
189
189
if attr_value is not None :
190
190
configreq [attr_name ] = attr_value
191
191
@@ -231,13 +231,6 @@ def setOptions(self):
231
231
help = "Set the maximum memory (in MB) used per job in this task." + \
232
232
" Default is 2000." )
233
233
234
- self .parser .add_option ('--numcores' ,
235
- dest = 'numcores' ,
236
- default = None ,
237
- type = 'int' ,
238
- help = "Set the number of cores used per job in this task." + \
239
- " (e.g.: 1 for single-threaded applications)." )
240
-
241
234
self .parser .add_option ('--priority' ,
242
235
dest = 'priority' ,
243
236
default = None ,
@@ -272,9 +265,9 @@ def validateOptions(self):
272
265
if self .options .publication :
273
266
if self .options .sitewhitelist is not None or self .options .siteblacklist is not None or \
274
267
self .options .maxjobruntime is not None or self .options .maxmemory is not None or \
275
- self .options .numcores is not None or self . options . priority is not None :
268
+ self .options .priority is not None :
276
269
msg = "The options --sitewhitelist, --siteblacklist,"
277
- msg += " --maxjobruntime, --maxmemory, --numcores and --priority"
270
+ msg += " --maxjobruntime, --maxmemory and --priority"
278
271
msg += " can not be specified together with the option --publication."
279
272
msg += " The last option is to only resubmit (failed) publications,"
280
273
msg += " in which case all of the first options make no sense."
@@ -310,7 +303,7 @@ def validateOptions(self):
310
303
311
304
## Covention used for the job parameters that the user can set when doing job
312
305
## resubmission (i.e. siteblacklist, sitewhitelist, maxjobruntime, maxmemory,
313
- ## numcores and priority):
306
+ ## and priority):
314
307
## - If the user doesn't set a parameter we don't pass it to the server and the
315
308
## the server copies the original value the parameter had at task submission.
316
309
## It copies it from the Task DB. Therefore we need to keep these parameters
@@ -354,11 +347,6 @@ def validateOptions(self):
354
347
msg = "The requested per-job memory (%d MB) must be between 30 and 30720 MB." % (self .options .maxmemory )
355
348
raise ConfigurationException (msg )
356
349
357
- if self .options .numcores is not None :
358
- if self .options .numcores < 1 or self .options .numcores > 128 :
359
- msg = "The requested number of cores (%d) must be between 1 and 128." % (self .options .numcores )
360
- raise ConfigurationException (msg )
361
-
362
350
if self .options .priority is not None :
363
351
if self .options .priority < 1 :
364
352
msg = "The requested priority (%d) must be greater than 0." % (self .options .priority )
0 commit comments