25 |
|
CAF is just a special queue and resources for LSF at CERN |
26 |
|
""" |
27 |
|
SchedulerLsf.configure(self, cfg_params) |
28 |
< |
self.queue = 'dedicated' |
29 |
< |
self.res = 'cmscaf' |
28 |
> |
self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf') |
29 |
> |
self.res = cfg_params.get(self.name().upper()+'.resource','cmscaf') |
30 |
> |
self.pool = cfg_params.get('USER.storage_pool','cmscafuser') |
31 |
|
|
32 |
|
def wsSetupEnvironment(self): |
33 |
|
""" |
35 |
|
""" |
36 |
|
txt = SchedulerLsf.wsSetupEnvironment(self) |
37 |
|
txt += '# CAF specific stuff\n' |
38 |
< |
txt += 'middleware=CAF \n' |
39 |
< |
txt += 'export STAGE_SVCCLASS=cmscaf \n' |
39 |
< |
|
38 |
> |
#txt += 'export STAGE_SVCCLASS=cmscaf \n' |
39 |
> |
txt += '\n' |
40 |
|
return txt |
41 |
|
|
42 |
+ |
def wsCopyOutput(self): |
43 |
+ |
### default is the name of the storage pool |
44 |
+ |
### where users can copy job outputs |
45 |
+ |
txt=self.wsCopyOutput_comm(self.pool) |
46 |
+ |
return txt |