CRAB/python/SchedulerGlidein.py

from SchedulerCondorCommon import SchedulerCondorCommon
import common

__revision__ = "$Id: SchedulerGlidein.py,v 1.12 2008/05/13 17:04:29 ewv Exp $"
__version__ = "$Revision: 1.12 $"

class SchedulerGlidein(SchedulerCondorCommon):
  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)

    ceDest = self.seListToCElist(task.jobs[i-1]['dlsDestination'], 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):
    ceDest = SchedulerCondorCommon.listMatch(seList, onlyOSG=False)
    return ceDest

Revision:	1.13
Committed:	Fri Jun 6 20:32:01 2008 UTC (16 years, 10 months ago) by ewv
Content type:	text/x-python
Branch:	MAIN
CVS Tags:	CRAB_DLS_PHED1, CRAB_DLS_PHED, CRAB_2_3_2_Fnal, CRAB_2_3_2, CRAB_2_3_2_pre7, CRAB_2_3_2_pre5, CRAB_2_3_2_pre4, CRAB_2_3_2_pre3, CRAB_2_3_2_pre2, CRAB_2_3_2_pre1, CRAB_2_4_0_test, CRAB_2_3_1, CRAB_2_3_1_pre6, CRAB_2_3_1_pre5, CRAB_2_3_1_pre4, CRAB_2_3_1_pre3, CRAB_2_3_1_pre2, CRAB_2_3_1_pre1, CRAB_2_3_0, CRAB_2_3_0_pre6, CRAB_2_3_0_pre1, CRAB_2_2_2_pre5
Branch point for:	AnaDataSet, CRAB_2_3_0_br
Changes since 1.12:	+4 -4 lines
Log Message:	Fix pythia on OSG. Still a little flakey
#	User	Rev	Content
1	ewv	1.1	from SchedulerCondorCommon import SchedulerCondorCommon
2			import common
3
4	ewv	1.13	__revision__ = "$Id: SchedulerGlidein.py,v 1.12 2008/05/13 17:04:29 ewv Exp $"
5			__version__ = "$Revision: 1.12 $"
6	ewv	1.1
7			class SchedulerGlidein(SchedulerCondorCommon):
8			def __init__(self):
9			SchedulerCondorCommon.__init__(self,"GLIDEIN")
10			return
11
12			def sched_parameter(self,i,task):
13			"""
14			Return scheduler-specific parameters
15			"""
16			jobParams = SchedulerCondorCommon.sched_parameter(self,i,task)
17
18	ewv	1.9	ceDest = self.seListToCElist(task.jobs[i-1]['dlsDestination'], onlyOSG=False)
19	ewv	1.5	ceString = ','.join(ceDest)
20	ewv	1.1
21	ewv	1.6	jobParams += '+DESIRED_Gatekeepers = "'+ceString+'"; '
22	ewv	1.1	jobParams += '+DESIRED_Archs = "INTEL,X86_64"; '
23	ewv	1.5	jobParams += "Requirements = stringListMember(GLIDEIN_Gatekeeper,DESIRED_Gatekeepers) && stringListMember(Arch,DESIRED_Archs); "
24	ewv	1.10	if (self.EDG_clock_time):
25			jobParams += '+MaxWallTimeMins = '+self.EDG_clock_time+'; '
26	ewv	1.13	else:
27	ewv	1.12	jobParams += '+MaxWallTimeMins = 120; '
28	ewv	1.1
29			common._db.updateTask_({'jobType':jobParams})
30			return jobParams # Not sure I even need to return anything
31	ewv	1.11
32	ewv	1.13	def listMatch(self, seList, full):
33	ewv	1.11	ceDest = SchedulerCondorCommon.listMatch(seList, onlyOSG=False)
34			return ceDest
35