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