| 1 |
|
from Scheduler import Scheduler |
| 2 |
|
from SchedulerLsf import SchedulerLsf |
| 3 |
|
from crab_exceptions import * |
| 4 |
– |
from crab_logger import Logger |
| 4 |
|
import common |
| 5 |
|
|
| 6 |
|
import os,string |
| 24 |
|
CAF is just a special queue and resources for LSF at CERN |
| 25 |
|
""" |
| 26 |
|
SchedulerLsf.configure(self, cfg_params) |
| 27 |
< |
self.queue = 'dedicated' |
| 28 |
< |
self.res = 'cmscaf' |
| 29 |
< |
|
| 30 |
< |
def wsSetupEnvironment(self): |
| 31 |
< |
""" |
| 32 |
< |
Returns part of a job script which does scheduler-specific work. |
| 33 |
< |
""" |
| 34 |
< |
txt = SchedulerLsf.wsSetupEnvironment(self) |
| 35 |
< |
txt += '# CAF specific stuff\n' |
| 36 |
< |
txt += 'middleware=CAF \n' |
| 37 |
< |
txt += 'export STAGE_SVCCLASS=cmscaf \n' |
| 38 |
< |
|
| 27 |
> |
self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf1nw') |
| 28 |
> |
self.res = cfg_params.get(self.name().upper()+'.resource','"type==SLC5_64 || type==SLC4_64"') |
| 29 |
> |
self.pool = cfg_params.get('USER.storage_pool','cmscafuser') |
| 30 |
> |
|
| 31 |
> |
# def wsSetupEnvironment(self): |
| 32 |
> |
# """ |
| 33 |
> |
# Returns part of a job script which does scheduler-specific work. |
| 34 |
> |
# """ |
| 35 |
> |
# txt = SchedulerLsf.wsSetupEnvironment(self) |
| 36 |
> |
# txt += '# CAF specific stuff\n' |
| 37 |
> |
# #txt += 'export STAGE_SVCCLASS=cmscaf \n' |
| 38 |
> |
# txt += '\n' |
| 39 |
> |
# return txt |
| 40 |
> |
|
| 41 |
> |
def wsCopyOutput(self): |
| 42 |
> |
### default is the name of the storage pool |
| 43 |
> |
### where users can copy job outputs |
| 44 |
> |
txt=self.wsCopyOutput_comm(self.pool) |
| 45 |
|
return txt |
| 41 |
– |
|
