ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/COMP/CRAB/python/SchedulerCaf.py
(Generate patch)

Comparing COMP/CRAB/python/SchedulerCaf.py (file contents):
Revision 1.16.2.1 by spiga, Tue Apr 13 18:06:33 2010 UTC vs.
Revision 1.20 by belforte, Thu Jun 14 15:40:30 2012 UTC

# Line 16 | Line 16 | class SchedulerCaf(SchedulerLsf) :
16      def __init__(self):
17          SchedulerLsf.__init__(self)
18          Scheduler.__init__(self,"CAF")
19 <        self.OSBsize = 55000000
19 >        self.OSBsize = 55*1000*1000  # 55 MB
20  
21          return
22  
# Line 28 | Line 28 | class SchedulerCaf(SchedulerLsf) :
28          self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf1nw')
29          self.res = cfg_params.get(self.name().upper()+'.resource','"type==SLC5_64 || type==SLC4_64"')
30          self.group = cfg_params.get(self.name().upper()+'.group', None)
31 –        self.pool = cfg_params.get('USER.storage_pool','cmscafuser')
31  
32      def sched_parameter(self,i,task):
33          """
# Line 42 | Line 41 | class SchedulerCaf(SchedulerLsf) :
41          if (self.group): sched_param += ' -G '+str(self.group).upper() +' '
42          return sched_param
43  
44 <
45 < #    def wsSetupEnvironment(self):
46 < #        """
47 < #        Returns part of a job script which does scheduler-specific work.
48 < #        """
49 < #        txt = SchedulerLsf.wsSetupEnvironment(self)
50 < #        txt += '# CAF specific stuff\n'
51 < #        #txt += 'export STAGE_SVCCLASS=cmscaf \n'
52 < #        txt += '\n'
53 < #        return txt
54 <
55 <    def wsCopyOutput(self):
56 <        ### default is the name of the storage pool
57 <        ### where users can copy job outputs  
58 <        txt=self.wsCopyOutput_comm(self.pool)
44 >    def wsSetupEnvironment(self):
45 >        #Returns part of a job script which does scheduler-specific work.
46 >        txt = SchedulerLsf.wsSetupEnvironment(self)
47 >        txt += '# CAF specific stuff\n'
48 >        txt += 'echo "----- ENV CAF BEFORE sourcing /afs/cern.ch/cms/caf/setup.sh  -----"\n'
49 >        txt += 'echo "CMS_PATH = $CMS_PATH"\n'
50 >        txt += 'echo "STAGE_SVCCLASS = $STAGE_SVCCLASS"\n'
51 >        txt += 'echo "STAGER_TRACE = $STAGER_TRACE"\n'
52 >        txt += 'source /afs/cern.ch/cms/caf/setup.sh \n'
53 >        txt += '\n'
54 >        txt += 'echo "----- ENV CAF AFTER sourcing /afs/cern.ch/cms/caf/setup.sh  -----"\n'
55 >        txt += 'echo "CMS_PATH = $CMS_PATH"\n'
56 >        txt += 'echo "STAGE_SVCCLASS = $STAGE_SVCCLASS"\n'
57 >        txt += 'echo "STAGER_TRACE = $STAGER_TRACE"\n'
58 >        txt += '\n'
59          return txt
60  
61      def wsExitFunc(self):

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines