| 25 |
|
CAF is just a special queue and resources for LSF at CERN |
| 26 |
|
""" |
| 27 |
|
SchedulerLsf.configure(self, cfg_params) |
| 28 |
< |
self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf') |
| 28 |
> |
self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf1nw') |
| 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 |
|
""" |
| 34 |
|
Returns part of a job script which does scheduler-specific work. |
| 35 |
|
""" |
| 36 |
|
txt = SchedulerLsf.wsSetupEnvironment(self) |
| 37 |
|
txt += '# CAF specific stuff\n' |
| 38 |
< |
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 |
