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 = 'dedicated'
        self.res = '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.2
Committed:	Mon Jan 7 18:20:20 2008 UTC (17 years, 3 months ago) by slacapra
Content type:	text/x-python
Branch:	MAIN
CVS Tags:	CRAB_2_1_0_pre5, CRAB_2_1_0_pre4, CRAB_2_1_0_pre3, CRAB_2_1_0_pre2
Changes since 1.1:	+2 -2 lines
Log Message:	introduce a SchedulerLocal class to reuse code for local scheduler such as LSF-PBS/Torque etc, as suggested by Stijn De Weirdt (thanks!)
#	User	Rev	Content
1	slacapra	1.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	slacapra	1.2	self.queue = 'dedicated'
29			self.res = 'cmscaf'
30	slacapra	1.1
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