26 |
|
SchedulerLsf.configure(self, cfg_params) |
27 |
|
self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf') |
28 |
|
self.res = cfg_params.get(self.name().upper()+'.resource','cmscaf') |
29 |
+ |
self.pool = cfg_params.get('USER.storage_pool','cmscafuser') |
30 |
|
|
31 |
|
def wsSetupEnvironment(self): |
32 |
|
""" |
34 |
|
""" |
35 |
|
txt = SchedulerLsf.wsSetupEnvironment(self) |
36 |
|
txt += '# CAF specific stuff\n' |
36 |
– |
#txt += 'export STAGE_SVCCLASS=cmscaf\n' |
37 |
|
txt += '\n' |
38 |
|
return txt |
39 |
|
|
40 |
|
def wsCopyOutput(self): |
41 |
|
### default is the name of the storage pool |
42 |
|
### where users can copy job outputs |
43 |
< |
pool='default' |
44 |
< |
txt=self.wsCopyOutput_tmp(pool) |
43 |
> |
txt=self.wsCopyOutput_tmp(self.pool) |
44 |
|
return txt |