python.AtlRunQuerySelectorWorker.SelectorWorker Class Reference

Collaboration diagram for python.AtlRunQuerySelectorWorker.SelectorWorker:

Classes
class	SelDescr

Public Member Functions
def	selectors (cls)
def	executedSelectors (cls)
def	getOrderedNeeds (cls, client)
def	addSelector (cls, selector, priority)
def	findSelectorDescriptor (cls, selname, selcls=None)
def	getShowSelector (cls, selname, *args, **kwargs)
def	CreateSelector (cls, selname, doesShow, *args, **kwargs)
def	getRetrieveSelector (cls, selname, selcls=None, *args, **kwargs)
def	getOrderedSelectorList (cls)
def	setApplySelection (cls)
def	setShowOutput (cls)
def	parseSelectorOptions (cls, options)
def	parseShowOption (cls, options)

Static Private Attributes
	__selectors
list	__executedSelectorsInOrder = []
list	__showSelectorsInOrder = []
dictionary	__selectorDependencies
dictionary	__creationRules

Detailed Description

Definition at line 15 of file AtlRunQuerySelectorWorker.py.

Member Function Documentation

addSelector()

def python.AtlRunQuerySelectorWorker.SelectorWorker.addSelector	(		cls,
			selector,
			priority
	)

Definition at line 99 of file AtlRunQuerySelectorWorker.py.

    def addSelector(cls, selector, priority):
        s = cls.findSelectorDescriptor(selector.name)
        if s:
            return s.selector
        cls.__selectors += [cls.SelDescr(selector=selector,priority=priority,doesSelect=True,doesShow=False,executed=False)]
        return cls.__selectors[-1].selector
 
 

CreateSelector()

def python.AtlRunQuerySelectorWorker.SelectorWorker.CreateSelector	(		cls,
			selname,
			doesShow,
		*	args,
		**	kwargs
	)

Definition at line 135 of file AtlRunQuerySelectorWorker.py.

    def CreateSelector( cls, selname, doesShow, *args, **kwargs):
        selcls = SelectorWorker.__creationRules[selname]
        thecls = eval('%s' % selcls)
        newsel = thecls(selname, *args, **kwargs)
        # print ("CREATING SELECTOR %s %s('%s')" % (("SHOW" if doesShow else "RETRIEVE"), selcls, selname))
        s = cls.SelDescr(selector=newsel, priority=0, doesSelect=False, doesShow=True, executed=False)
        return s
 
    

executedSelectors()

def python.AtlRunQuerySelectorWorker.SelectorWorker.executedSelectors

(

cls

)

Definition at line 80 of file AtlRunQuerySelectorWorker.py.

    def executedSelectors(cls):
        for s in cls.__executedSelectorsInOrder:
            yield s.selector
 

findSelectorDescriptor()

def python.AtlRunQuerySelectorWorker.SelectorWorker.findSelectorDescriptor	(		cls,
			selname,
			selcls = None
	)

returns a SelDescr if name and class match

Definition at line 109 of file AtlRunQuerySelectorWorker.py.

    def findSelectorDescriptor(cls, selname, selcls=None):
        """ returns a SelDescr if name and class match"""
        for s in cls.__selectors:
            if s.selector.name == selname and (selcls is None or selcls==s.selector.__class__.__name__):
                return s
        return None
 

getOrderedNeeds()

def python.AtlRunQuerySelectorWorker.SelectorWorker.getOrderedNeeds	(		cls,
			client
	)

Definition at line 85 of file AtlRunQuerySelectorWorker.py.

    def getOrderedNeeds(cls, client):
        needs = []
        selname = client.selector.name
        if selname in cls.__selectorDependencies:
            dependson = cls.__selectorDependencies[selname]
            for d in dependson:
                dep = cls.findSelectorDescriptor(d)
                if dep is None:
                    raise RuntimeError('Selector %s depends on %s which is not defined' % (selname,d))
                needs.insert(0, dep)
        return needs
 
    

getOrderedSelectorList()

def python.AtlRunQuerySelectorWorker.SelectorWorker.getOrderedSelectorList

(

cls

)

Definition at line 162 of file AtlRunQuerySelectorWorker.py.

    def getOrderedSelectorList(cls):
        # Highes priority first
        sortedSel = cls.__selectors
        sortedSel.sort(key = lambda x: x.priority, reverse=True)
        return sortedSel
 

getRetrieveSelector()

def python.AtlRunQuerySelectorWorker.SelectorWorker.getRetrieveSelector	(		cls,
			selname,
			selcls = None,
		*	args,
		**	kwargs
	)

Definition at line 145 of file AtlRunQuerySelectorWorker.py.

    def getRetrieveSelector(cls, selname, selcls=None, *args, **kwargs):
        s = cls.findSelectorDescriptor(selname, selcls)
        if s:
            try:
                s.selector.addShowSelector()
            except Exception:
                pass
            return s.selector
        elif selcls is not None:
            s = cls.CreateSelector( selname, False, *args, **kwargs)
            cls.__selectors += [s]
            return s.selector
        else:
            return None
    
 

getShowSelector()

def python.AtlRunQuerySelectorWorker.SelectorWorker.getShowSelector	(		cls,
			selname,
		*	args,
		**	kwargs
	)

Definition at line 117 of file AtlRunQuerySelectorWorker.py.

    def getShowSelector(cls, selname, *args, **kwargs):
        selcls = SelectorWorker.__creationRules[selname]
        # see if the selector is already there
        s = cls.findSelectorDescriptor(selname, selcls)
        if s:
            s.doesShow=True
            cls.__showSelectorsInOrder += [s]
            try:
                s.selector.addShowSelector(*args, **kwargs)
            except Exception:
                pass
        else:
            s = cls.CreateSelector( selname, True, *args, **kwargs)
            cls.__showSelectorsInOrder += [s]
            cls.__selectors += [s]
        return s.selector
 

parseSelectorOptions()

def python.AtlRunQuerySelectorWorker.SelectorWorker.parseSelectorOptions	(		cls,
			options
	)

Definition at line 180 of file AtlRunQuerySelectorWorker.py.

    def parseSelectorOptions(cls,options):
 
        if options.events:
            cls.addSelector( EventSelector(name = 'events', events = options.events), 280 )
 
        if options.larcond:
            cls.addSelector( LArcondSelector(name = 'larcond', larcond = options.larcond), 115 )
 
        if options.datasets:
            cls.addSelector( DatasetsSelector(name = 'datasets', datasets = options.datasets), 110 )
 
        if options.duration:
            cls.addSelector( DurationSelector(name = 'duration', duration = options.duration), 95 )
 
        if options.streams:
            cls.addSelector( StreamSelector(name = 'streams', streams = options.streams), 95 )
 
        if options.smklist:
            cls.addSelector( TrigKeySelector(name = 'trigkey'), 71 ).setSelectSMK(smks = options.smklist)
 
        if options.release:
            cls.addSelector( TrigKeySelector(name = 'trigkey'), 70 ).setSelectRelease(release = options.release)
 
        if options.detmaskin or options.detmaskout:
            cls.addSelector( DetectorSelector('detmask', options.detmaskin, options.detmaskout), 60 )
 
        if options.lhc:
            cls.addSelector( LHCSelector(name = 'lhc', lhc = options.lhc), 48 )
 
        if options.beamspot:
            cls.addSelector( BeamspotSelector(name = 'beamspot', beamspot = options.beamspot), 44 )
 
        if options.olclumi:
            cls.addSelector( OLCLumiSelector(name = 'olclumi', olclumi = options.olclumi), 43 )
 
        if options.bpm:
            cls.addSelector( BPMSelector(name = 'bpm', release = options.bpm), 40 )
 
        if options.luminosity:
            cls.addSelector( LuminositySelector(name = 'luminosity', luminosity = options.luminosity), 40 )
 
        if options.projecttag:
            cls.addSelector( FilenameSelector(name = 'filenametag', projecttag = options.projecttag), 40 )
 
        if options.readyforphysics:
            cls.addSelector( ReadyForPhysicsSelector(name = 'readyforphysics', readyforphysics = options.readyforphysics), 31 )
 
        if options.partition:
            cls.addSelector( PartitionSelector(name = 'partition', partition = options.partition), 300 )
        
        if options.trigger:
            cls.addSelector( TriggerSelector(name = 'trigger', trigger = options.trigger), 25 )
 
        if options.bfield:
            cls.addSelector( BFieldSelector(name = 'bfield', bf = options.bfield), 10 )
 
        if options.dqchannels:
            cls.addSelector( DQSelector(), 50 ).addSelectionChannel(options.dqchannels)
 
 
 
 

parseShowOption()

def python.AtlRunQuerySelectorWorker.SelectorWorker.parseShowOption	(		cls,
			options
	)

Definition at line 243 of file AtlRunQuerySelectorWorker.py.

    def parseShowOption(cls,options):
        if not options.show:
            return
 
        for s in options.show:
 
            if s == 'summary' or s == 'dqeff' or s == 'dqsummary' or s == 'dqplots'  or s == 'cosmics'  or s == 'heavyions':
                pass # handled outside
 
            elif s=='run':
                Run.showrunnr = True
 
            elif s=='time':
                Run.showtime = True
 
            elif s=='duration':
                Run.showduration = True
 
            elif s[0:3]=='dq ' or s=='dq':
                SelectorWorker.getShowSelector('dataquality').addShowChannel(s[3:])
 
            elif s[0:7] == 'streams':
                SelectorWorker.getShowSelector('streams').addShowStreamPattern(s[8:])
 
            elif s[0:7] == 'trigger':
                SelectorWorker.getShowSelector('trigger').addShowTriggerPattern(s[8:])
 
            elif s[0:8] == 'datasets':
                SelectorWorker.getShowSelector('datasets').addShowDatasetPattern(s[9:])
 
            elif s[0:9] == 'trigrates':
                SelectorWorker.getShowSelector('rates').addPattern(s[10:])
 
            elif s[0:3] == 'lhc':
                arg = ''
                if   'all' in s:
                    arg = 'all'
                elif 'min' in s:
                    arg = 'min'
                SelectorWorker.getShowSelector('lhc',addArg=arg)
 
            elif 'olclumi' in s:
                SelectorWorker.getShowSelector(s)
 
            elif s == 'smk':
                SelectorWorker.getShowSelector('trigkey').setShow('smk')
 
            elif s == 'trigkeys' or s == 'smk':
                SelectorWorker.getShowSelector('trigkey').setShow('smk')
                SelectorWorker.getShowSelector('l1trigkey')
                SelectorWorker.getShowSelector('hlttrigkey')
                SelectorWorker.getShowSelector('bgskey')
 
            elif s == 'release':
                SelectorWorker.getShowSelector('trigkey').setShow('release')
 
            elif s[0:10] == 'luminosity':
                SelectorWorker.getShowSelector('luminosity').addShowTag(s.split(None,1)[1])
 
            elif s[0:8] == 'beamspot':
                SelectorWorker.getShowSelector('beamspot',args=s[8:])
 
            elif s[0:3] == 'bpm':
                SelectorWorker.getShowSelector('bpm')
 
            elif s == 'filenametag' or s == 'projecttag':
                SelectorWorker.getShowSelector('filenametag')
 
            elif s in ['bfield', 'events', 'allevents', 'detmask', 'olcfillparams', 'olclbdata', 'datasets', 'partition', 'readyforphysics', 'larcond']:
                SelectorWorker.getShowSelector(s)
 
            else:
                raise RuntimeError("ERROR: option 'show %s' not implemented" %s)
 

selectors()

def python.AtlRunQuerySelectorWorker.SelectorWorker.selectors

(

cls

)

Definition at line 64 of file AtlRunQuerySelectorWorker.py.

    def selectors(cls):
        for s in SelectorWorker.getOrderedSelectorList():
            if s.executed:
                continue
            needs = cls.getOrderedNeeds(s)
            for ss in needs:
                if ss.executed:
                    continue
                yield ss.selector
                cls.__executedSelectorsInOrder += [ss]
                ss.executed=True
            yield s.selector
            cls.__executedSelectorsInOrder += [s]
            s.executed=True
 

setApplySelection()

def python.AtlRunQuerySelectorWorker.SelectorWorker.setApplySelection

(

cls

)

Definition at line 169 of file AtlRunQuerySelectorWorker.py.

    def setApplySelection(cls):
        for s in cls.__selectors:
            s.selector.applySelection = s.doesSelect
 

setShowOutput()

def python.AtlRunQuerySelectorWorker.SelectorWorker.setShowOutput

(

cls

)

Definition at line 174 of file AtlRunQuerySelectorWorker.py.

    def setShowOutput(cls):
        for s in cls.__showSelectorsInOrder:
            s.selector.setShowOutput()
 
        

Member Data Documentation

__creationRules

dictionary python.AtlRunQuerySelectorWorker.SelectorWorker.__creationRules

staticprivate

Initial value:

=  {
        'dataquality'     : 'DQSelector',
        'streams'         : 'StreamSelector',
        'trigger'         : 'TriggerSelector',
        'datasets'        : 'DatasetsSelector',
        'rates'           : 'RatesSelector',
        'lhc'             : 'LHCSelector',
        'bfield'          : 'BFieldSelector',
        'events'          : 'EventSelector',
        'allevents'       : 'AllEventsSelector',
        'release'         : 'TrigKeySelector',
        'trigkey'         : 'TrigKeySelector',
        'l1trigkey'       : 'L1TrigKeySelector',
        'hlttrigkey'      : 'HLTTrigKeySelector',
        'bgskey'          : 'BGSKeySelector',
        'detmask'         : 'DetectorSelector',
        'olclumi'         : 'OLCLumiSelector',
        'olcfillparams'   : 'OLCFillParamsCondition',
        'olclbdata'       : 'OLCLBDataCondition',
        'datasets'        : 'DatasetsSelector',
        'partition'       : 'PartitionSelector',
        'readyforphysics' : 'ReadyForPhysicsSelector',
        'larcond'         : 'LArcondSelector',
        'luminosity'      : 'LuminositySelector',
        'beamspot'        : 'BeamspotSelector',
        'bpm'             : 'BPMSelector',
        'filenametag'     : 'FilenameSelector'
        }

Definition at line 33 of file AtlRunQuerySelectorWorker.py.

__executedSelectorsInOrder

list python.AtlRunQuerySelectorWorker.SelectorWorker.__executedSelectorsInOrder = []

staticprivate

Definition at line 27 of file AtlRunQuerySelectorWorker.py.

__selectorDependencies

dictionary python.AtlRunQuerySelectorWorker.SelectorWorker.__selectorDependencies

staticprivate

Initial value:

=  { 'trigger':['trigkey','l1trigkey','hlttrigkey'],
                               'dataquality':['readyforphysics']
                               }

Definition at line 29 of file AtlRunQuerySelectorWorker.py.

__selectors

python.AtlRunQuerySelectorWorker.SelectorWorker.__selectors

staticprivate

Definition at line 26 of file AtlRunQuerySelectorWorker.py.

__showSelectorsInOrder

list python.AtlRunQuerySelectorWorker.SelectorWorker.__showSelectorsInOrder = []

staticprivate

Definition at line 28 of file AtlRunQuerySelectorWorker.py.

---

The documentation for this class was generated from the following file:

• AtlRunQuerySelectorWorker.py