CRAB/python/SchedulerCaf.py

from Scheduler import Scheduler
from SchedulerLsf import SchedulerLsf
from crab_exceptions import *
import common

import os,string

#
#  Naming convention:
#  methods starting with 'ws' are responsible to provide
#  corresponding part of the job script ('ws' stands for 'write script').
#

class SchedulerCaf(SchedulerLsf) :

    def __init__(self):
        SchedulerLsf.__init__(self)
        Scheduler.__init__(self,"CAF")

        return

    def configure(self, cfg_params):
        """
        CAF is just a special queue and resources for LSF at CERN
        """
        SchedulerLsf.configure(self, cfg_params)
        self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf1nw')
        self.res = cfg_params.get(self.name().upper()+'.resource','cmscaf')
        self.pool = cfg_params.get('USER.storage_pool','cmscafuser')

    def wsSetupEnvironment(self):
        """
        Returns part of a job script which does scheduler-specific work.
        """
        txt = SchedulerLsf.wsSetupEnvironment(self)
        txt += '# CAF specific stuff\n'
        #txt += 'export STAGE_SVCCLASS=cmscaf \n'
        txt += '\n'
        return txt

    def wsCopyOutput(self):
        ### default is the name of the storage pool 
        ### where users can copy job outputs  
        txt=self.wsCopyOutput_comm(self.pool)
        return txt
Revision:	1.12
Committed:	Tue May 26 10:23:01 2009 UTC (15 years, 11 months ago) by spiga
Content type:	text/x-python
Branch:	MAIN
CVS Tags:	CRAB_2_6_1_pre1, CRAB_2_6_0, CRAB_2_6_0_pre14, CRAB_2_6_0_pre13, CRAB_2_6_0_pre12, CRAB_2_6_0_pre11, CRAB_2_6_0_pre10, CRAB_2_6_0_pre9, CRAB_2_6_0_pre8, CRAB_2_6_0_pre7, CRAB_2_6_0_pre6, CRAB_2_6_0_pre5, CRAB_2_6_0_pre4, CRAB_2_6_0_pre3
Changes since 1.11:	+0 -1 lines
Log Message:	adapting code to logging usage. (crab_logger removed)
#	User	Rev	Content
1	slacapra	1.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	spiga	1.11	self.queue = cfg_params.get(self.name().upper()+'.queue','cmscaf1nw')
28	spiga	1.5	self.res = cfg_params.get(self.name().upper()+'.resource','cmscaf')
29	fanzago	1.9	self.pool = cfg_params.get('USER.storage_pool','cmscafuser')
30
31	slacapra	1.1	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	fanzago	1.9	#txt += 'export STAGE_SVCCLASS=cmscaf \n'
38			txt += '\n'
39			return txt
40	slacapra	1.1
41	fanzago	1.9	def wsCopyOutput(self):
42			### default is the name of the storage pool
43			### where users can copy job outputs
44	spiga	1.10	txt=self.wsCopyOutput_comm(self.pool)
45	slacapra	1.1	return txt