CRAB/python/SchedulerCaf.py

from Scheduler import Scheduler
from SchedulerLsf import SchedulerLsf
from crab_exceptions import *
from crab_logger import Logger
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()+'.queue','dedicated')
        self.res = cfg_params.get(self.name()+'.resource','cmscaf')

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

        return txt

Revision:	1.4
Committed:	Mon Feb 25 18:19:58 2008 UTC (17 years, 2 months ago) by spiga
Content type:	text/x-python
Branch:	MAIN
CVS Tags:	CRAB_2_2_0_pre13, CRAB_2_2_0_pre12, CRAB_2_2_0_pre11, CRAB_2_2_0_pre10, bp_osg_bdii, CRAB_2_2_0_pre9, CRAB_2_2_0_pre8, CRAB_2_2_0_pre7, CRAB_2_1_2, CRAB_2_2_0_pre5, CRAB_2_1_2_pre2, CRAB_2_1_2_pre1, CRAB_2_2_0_pre4, CRAB_2_2_0_pre2, CRAB_2_1_1, CRAB_2_1_1_pre3, CRAB_2_2_0_pre1, CRAB_2_1_1_pre1
Branch point for:	osg_bdii, CRAB_2_1_2_br, CRAB_2_1_1_pre2
Changes since 1.3:	+2 -2 lines
Log Message:	minor fix
#	Content
1	from Scheduler import Scheduler
2	from SchedulerLsf import SchedulerLsf
3	from crab_exceptions import *
4	from crab_logger import Logger
5	import common
6
7	import os,string
8
9	#
10	# Naming convention:
11	# methods starting with 'ws' are responsible to provide
12	# corresponding part of the job script ('ws' stands for 'write script').
13	#
14
15	class SchedulerCaf(SchedulerLsf) :
16
17	def __init__(self):
18	SchedulerLsf.__init__(self)
19	Scheduler.__init__(self,"CAF")
20
21	return
22
23	def configure(self, cfg_params):
24	"""
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()+'.queue','dedicated')
29	self.res = cfg_params.get(self.name()+'.resource','cmscaf')
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 += 'middleware=CAF \n'
38	txt += 'export STAGE_SVCCLASS=cmscaf \n'
39
40	return txt
41