| Revision: | 1.14 |
| Committed: | Wed Jul 22 17:56:10 2009 UTC (15 years, 9 months ago) by spiga |
| Content type: | text/x-python |
| Branch: | MAIN |
| CVS Tags: | CRAB_2_7_0_pre8, CRAB_2_6_5_pre1, CRAB_2_7_0_pre7, CRAB_2_6_4, CRAB_2_7_0_pre6, CRAB_2_6_4_pre1, CRAB_2_7_0_pre5, CRAB_2_6_3_patch_2, CRAB_2_6_3_patch_2_pre2, CRAB_2_6_3_patch_2_pre1, CRAB_2_6_3_patch_1, CRAB_2_7_0_pre4, CRAB_2_7_0_pre3, CRAB_2_6_3, CRAB_2_6_3_pre5, CRAB_2_6_3_pre4, CRAB_2_6_3_pre3, CRAB_2_6_3_pre2, CRAB_2_7_0_pre2, CRAB_2_6_3_pre1, test_1, CRAB_2_7_0_pre1, CRAB_2_6_2, CRAB_2_6_2_pre2, CRAB_2_6_2_pre1, CRAB_2_6_1 |
| Branch point for: | Lumi2_8, CRAB_2_6_X_br |
| Changes since 1.13: | +1 -1 lines |
| Log Message: | syntax |
| # | Content |
|---|---|
| 1 | from Scheduler import Scheduler |
| 2 | from SchedulerLsf import SchedulerLsf |
| 3 | from crab_exceptions import * |
| 4 | import common |
| 5 | |
| 6 | import os,string |
| 7 | |
| 8 | # |
| 9 | # Naming convention: |
| 10 | # methods starting with 'ws' are responsible to provide |
| 11 | # corresponding part of the job script ('ws' stands for 'write script'). |
| 12 | # |
| 13 | |
| 14 | class SchedulerCaf(SchedulerLsf) : |
| 15 | |
| 16 | def __init__(self): |
| 17 | SchedulerLsf.__init__(self) |
| 18 | Scheduler.__init__(self,"CAF") |
| 19 | |
| 20 | return |
| 21 | |
| 22 | def configure(self, cfg_params): |
| 23 | """ |
| 24 | CAF is just a special queue and resources for LSF at CERN |
| 25 | """ |
| 26 | SchedulerLsf.configure(self, cfg_params) |
| 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 |