CRAB/python/SchedulerGlidein.py

"""
Glidein specific portions of the interface to the BossLite scheduler
"""

__revision__ = "$Id: SchedulerGlidein.py,v 1.15 2008/09/29 21:14:28 ewv Exp $"
__version__ = "$Revision: 1.15 $"

from SchedulerCondorCommon import SchedulerCondorCommon
import common

class SchedulerGlidein(SchedulerCondorCommon):
    """
    Glidein specific portions of the interface to the BossLite scheduler
    """

    def __init__(self):
        SchedulerCondorCommon.__init__(self,"GLIDEIN")
        return

    def sched_parameter(self, i, task):
        """
        Return scheduler-specific parameters
        """
        jobParams = SchedulerCondorCommon.sched_parameter(self, i, task)
        seDest = task.jobs[i-1]['dlsDestination']
        ceDest = self.seListToCElist(seDest, onlyOSG=False)
        ceString = ','.join(ceDest)

        jobParams += '+DESIRED_Gatekeepers = "'+ceString+'"; '
        jobParams += '+DESIRED_Archs = "INTEL,X86_64"; '
        jobParams += "Requirements = stringListMember(GLIDEIN_Gatekeeper,DESIRED_Gatekeepers) &&  stringListMember(Arch,DESIRED_Archs); "
        if (self.EDG_clock_time):
            jobParams += '+MaxWallTimeMins = '+self.EDG_clock_time+'; '
        else:
            jobParams += '+MaxWallTimeMins = 120; '

        common._db.updateTask_({'jobType':jobParams})
        return jobParams # Not sure I even need to return anything

    def listMatch(self, seList, full, onlyOSG=False):
        """
        Check the compatibility of available resources
        """
        ceDest = SchedulerCondorCommon.listMatch(self, seList, full, onlyOSG=False)
        return ceDest

Revision:	1.17
Committed:	Thu Jun 11 19:25:12 2009 UTC (15 years, 10 months ago) by ewv
Content type:	text/x-python
Branch:	MAIN
CVS Tags:	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_pre4, CRAB_2_6_1_pre3, CRAB_2_6_1_pre2, CRAB_2_6_1_pre1, CRAB_2_6_1, 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
Branch point for:	CRAB_2_6_X_br
Changes since 1.16:	+40 -57 lines
Log Message:	Revert to CRAB version of SchedulerGlidein, not BossLite
#	User	Rev	Content
1	ewv	1.14	"""
2	ewv	1.17	Glidein specific portions of the interface to the BossLite scheduler
3	ewv	1.14	"""
4
5	ewv	1.17	__revision__ = "$Id: SchedulerGlidein.py,v 1.15 2008/09/29 21:14:28 ewv Exp $"
6			__version__ = "$Revision: 1.15 $"
7	ewv	1.14
8	ewv	1.17	from SchedulerCondorCommon import SchedulerCondorCommon
9			import common
10	ewv	1.1
11	ewv	1.17	class SchedulerGlidein(SchedulerCondorCommon):
12			"""
13			Glidein specific portions of the interface to the BossLite scheduler
14			"""
15
16			def __init__(self):
17			SchedulerCondorCommon.__init__(self,"GLIDEIN")
18			return
19
20			def sched_parameter(self, i, task):
21			"""
22			Return scheduler-specific parameters
23			"""
24			jobParams = SchedulerCondorCommon.sched_parameter(self, i, task)
25			seDest = task.jobs[i-1]['dlsDestination']
26			ceDest = self.seListToCElist(seDest, onlyOSG=False)
27			ceString = ','.join(ceDest)
28
29			jobParams += '+DESIRED_Gatekeepers = "'+ceString+'"; '
30			jobParams += '+DESIRED_Archs = "INTEL,X86_64"; '
31			jobParams += "Requirements = stringListMember(GLIDEIN_Gatekeeper,DESIRED_Gatekeepers) && stringListMember(Arch,DESIRED_Archs); "
32			if (self.EDG_clock_time):
33			jobParams += '+MaxWallTimeMins = '+self.EDG_clock_time+'; '
34			else:
35			jobParams += '+MaxWallTimeMins = 120; '
36
37			common._db.updateTask_({'jobType':jobParams})
38			return jobParams # Not sure I even need to return anything
39
40			def listMatch(self, seList, full, onlyOSG=False):
41			"""
42			Check the compatibility of available resources
43			"""
44			ceDest = SchedulerCondorCommon.listMatch(self, seList, full, onlyOSG=False)
45			return ceDest
46	ewv	1.11