Skip to content

Commit

Permalink
* removed constraint from the brokerage so that many input jobs can g…
Browse files Browse the repository at this point in the history
…o to T2

* added HIMEM to hospital
  • Loading branch information
tmaeno committed Oct 9, 2013
1 parent e2471c7 commit 643d463
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 1 deletion.
2 changes: 2 additions & 0 deletions README.txt
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
Release Note

current
* removed constraint from the brokerage so that many input jobs can go to T2
* added HIMEM to hospital
* improved the brokerage to use mintime
* changed add.py not to run around log rotate
* dusted getNUserJobs off
Expand Down
4 changes: 3 additions & 1 deletion pandaserver/brokerage/broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -335,7 +335,7 @@ def getT2CandList(tmpJob,siteMapper,t2FilesMap):
def getHospitalQueues(siteMapper):
retMap = {}
# hospital words
goodWordList = ['CORE$','VL$','MEM$','MP\d+$','LONG$']
goodWordList = ['CORE$','VL$','MEM$','MP\d+$','LONG$','_HIMEM']
# loop over all clouds
for tmpCloudName in siteMapper.getCloudList():
# get cloud
Expand Down Expand Up @@ -644,6 +644,7 @@ def schedule(jobs,taskBuffer,siteMapper,forAnalysis=False,setScanSiteList=[],tru
tmpLog.debug('PandaID:%s -> set SiteList=%s for high prio' % (job.PandaID,specialBrokergageSiteList))
brokerageNote = 'highPrio'
# set computingSite to T1 when too many inputs are required
"""
if job != None and job.computingSite == 'NULL' and job.prodSourceLabel in ('test','managed') \
and specialBrokergageSiteList == []:
# counts # of inputs
Expand All @@ -658,6 +659,7 @@ def schedule(jobs,taskBuffer,siteMapper,forAnalysis=False,setScanSiteList=[],tru
specialBrokergageSiteList += hospitalQueueMap[job.cloud]
tmpLog.debug('PandaID:%s -> set SiteList=%s for too many inputs' % (job.PandaID,specialBrokergageSiteList))
brokerageNote = 'manyInput'
"""
# use limited sites for reprocessing
if job != None and job.computingSite == 'NULL' and job.prodSourceLabel in ('test','managed') \
and job.processingType in ['reprocessing'] and specialBrokergageSiteList == []:
Expand Down

0 comments on commit 643d463

Please sign in to comment.