| 1 |
ewv |
1.1 |
from SchedulerCondorCommon import SchedulerCondorCommon
|
| 2 |
|
|
import common
|
| 3 |
|
|
|
| 4 |
spiga |
1.4 |
__revision__ = "$Id: SchedulerGlidein.py,v 1.3 2008/04/17 21:23:52 ewv Exp $"
|
| 5 |
|
|
__version__ = "$Revision: 1.3 $"
|
| 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 |
spiga |
1.4 |
seDest = self.blackWhiteListParser.cleanForBlackWhiteList(task.jobs[i-1]['dlsDestination'])
|
| 19 |
ewv |
1.1 |
#ceDest = self.getCEfromSE(seDest)
|
| 20 |
|
|
|
| 21 |
|
|
# FIXME: Translate seDest into glidein name using SiteDB
|
| 22 |
|
|
|
| 23 |
ewv |
1.2 |
jobParams += '+DESIRED_Sites = "T2_US_UCSD"; '
|
| 24 |
ewv |
1.1 |
jobParams += '+DESIRED_Archs = "INTEL,X86_64"; '
|
| 25 |
|
|
jobParams += "Requirements = stringListMember(GLIDEIN_Site,DESIRED_Sites) && stringListMember(Arch,DESIRED_Archs); "
|
| 26 |
|
|
|
| 27 |
|
|
common._db.updateTask_({'jobType':jobParams})
|
| 28 |
|
|
return jobParams # Not sure I even need to return anything
|
