28 |
|
self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf1nw') |
29 |
|
self.res = cfg_params.get(self.name().upper()+'.resource','"type==SLC5_64 || type==SLC4_64"') |
30 |
|
self.group = cfg_params.get(self.name().upper()+'.group', None) |
31 |
– |
self.pool = cfg_params.get('USER.storage_pool','cmscafuser') |
31 |
|
|
32 |
|
def sched_parameter(self,i,task): |
33 |
|
""" |
41 |
|
if (self.group): sched_param += ' -G '+str(self.group).upper() +' ' |
42 |
|
return sched_param |
43 |
|
|
45 |
– |
###### FEDE FOR 84387 bug ###### |
44 |
|
def wsSetupEnvironment(self): |
45 |
|
#Returns part of a job script which does scheduler-specific work. |
46 |
|
txt = SchedulerLsf.wsSetupEnvironment(self) |
57 |
|
txt += 'echo "STAGER_TRACE = $STAGER_TRACE"\n' |
58 |
|
txt += '\n' |
59 |
|
return txt |
62 |
– |
############################# |
63 |
– |
|
64 |
– |
def wsCopyOutput(self): |
65 |
– |
### default is the name of the storage pool |
66 |
– |
### where users can copy job outputs |
67 |
– |
txt=self.wsCopyOutput_comm(self.pool) |
68 |
– |
return txt |
60 |
|
|
61 |
|
def wsExitFunc(self): |
62 |
|
""" |