15 |
|
|
16 |
|
def __init__(self): |
17 |
|
SchedulerCondorCommon.__init__(self,"GLIDEIN") |
18 |
+ |
self.environment_unique_identifier = '$Glidein_MonitorID' |
19 |
|
return |
20 |
|
|
21 |
+ |
|
22 |
|
def sched_parameter(self, i, task): |
23 |
|
""" |
24 |
|
Return scheduler-specific parameters |
34 |
|
if (self.EDG_clock_time): |
35 |
|
jobParams += '+MaxWallTimeMins = '+self.EDG_clock_time+'; ' |
36 |
|
else: |
37 |
< |
jobParams += '+MaxWallTimeMins = 120; ' |
37 |
> |
jobParams += '+MaxWallTimeMins = 1440; ' |
38 |
|
|
39 |
|
common._db.updateTask_({'jobType':jobParams}) |
40 |
|
return jobParams # Not sure I even need to return anything |
41 |
|
|
42 |
+ |
|
43 |
|
def listMatch(self, seList, full, onlyOSG=False): |
44 |
|
""" |
45 |
|
Check the compatibility of available resources |
46 |
|
""" |
47 |
< |
ceDest = SchedulerCondorCommon.listMatch(seList, onlyOSG=False) |
47 |
> |
ceDest = SchedulerCondorCommon.listMatch(self, seList, full, onlyOSG=False) |
48 |
|
return ceDest |
49 |
|
|
50 |
+ |
|
51 |
+ |
def envUniqueID(self): |
52 |
+ |
msg = 'JobID for ML monitoring is created for Glidein scheduler: %s'%id |
53 |
+ |
common.logger.debug(msg) |
54 |
+ |
return '$Glidein_MonitorID' |