Collaboration diagram for python.AtlRunQueryRun.RunData:

Public Member Functions
	__init__ (self, run)
	__contains__ (self, k)
	__getitem__ (self, k)
	__setitem__ (self, k, value)
	__iter__ (self)
	keys (self)
	runNrS (self)
	lb (self)
	lbend (self, lb=None)
	NrLBs (self)
	result (self)
	isRejectedCurrentLB (self)
	isDQRejected (self)
	isDQDefectRejected (self)
	isRejected (self)
	isReady (self, lb=None)
	getLBRanges (self, activeOnly=False)
	addResult (self, iov, k, value, reject, valueForStorage=None)
	astxt (self)

Public Attributes
	run = run.runNr
dict	data = {}
dict	data_current_lb = {}
int	current_lb = 0
list	stops = []

Static Public Attributes
list	DQKeys = []
list	DQLogic = []
	DefectSelector = None

Protected Member Functions
	_setLB (self, lb)
	_calcStops (self)

Private Attributes
	__run_o = run

Detailed Description

Definition at line 119 of file AtlRunQueryRun.py.

Constructor & Destructor Documentation

◆ init()

python.AtlRunQueryRun.RunData.__init__	(		self,
			run )

Definition at line 126 of file AtlRunQueryRun.py.

    def __init__(self,run):
        self.__run_o  = run
        self.run  = run.runNr
        self.data = {}
        self.data_current_lb = {}
        self.current_lb = 0
        self.stops = []
 

Member Function Documentation

◆ contains()

python.AtlRunQueryRun.RunData.__contains__	(		self,
			k )

Definition at line 134 of file AtlRunQueryRun.py.

    def __contains__(self,k):
        if type(k)==DataKey:
            return k in self.data or k.ResultKey in self.data
        return k in self.data
 

◆ getitem()

python.AtlRunQueryRun.RunData.__getitem__	(		self,
			k )

Definition at line 139 of file AtlRunQueryRun.py.

    def __getitem__(self,k):
        if k not in self:
            self.data[k] = DataEntryList(key=k, run=self.run)
            return self.data[k]
        else:
            if type(k)==DataKey:
                return self.data[k] if k in self.data else self.data[k.ResultKey]
            return self.data[k]
 

◆ iter()

python.AtlRunQueryRun.RunData.__iter__ ( self )

Definition at line 151 of file AtlRunQueryRun.py.

    def __iter__(self):
        self.stops = self._calcStops()
        for lb in self.stops: # the last stop is the LB after the last
            if lb>self.__run_o.lastlb:
                break
            self._setLB(lb)
            yield self
 

◆ setitem()

python.AtlRunQueryRun.RunData.__setitem__	(	self,
		k,
		value )

Definition at line 148 of file AtlRunQueryRun.py.

    def __setitem__(self,k,value):
        self.data[k]=value
 

◆ _calcStops()

python.AtlRunQueryRun.RunData._calcStops ( self )

protected

Definition at line 279 of file AtlRunQueryRun.py.

    def _calcStops(self):
        stops = set()
        for entrylist in self.data.values():
            stops.update(entrylist.stops())
        return sorted(list(stops))
 

◆ _setLB()

python.AtlRunQueryRun.RunData._setLB	(		self,
			lb )

protected

Definition at line 275 of file AtlRunQueryRun.py.

    def _setLB(self,lb):
        self.current_lb = lb
        self.data_current_lb = dict([(k,entrylist.atLB(lb)) for k,entrylist in self.data.items()])
 

◆ addResult()

python.AtlRunQueryRun.RunData.addResult	(	self,
		iov,
		k,
		value,
		reject,
		valueForStorage = None )

Definition at line 285 of file AtlRunQueryRun.py.

    def addResult(self, iov, k, value, reject, valueForStorage = None):
        if not iov:
            iov = IOVRange(runStart=self.run, lbStart=1, runEnd=self.run+1, lbEnd=0)
        self[k].append(DataEntry(iov=iov, value=value, reject=reject, valueForStorage=valueForStorage))
 

◆ astxt()

python.AtlRunQueryRun.RunData.astxt ( self )

Definition at line 290 of file AtlRunQueryRun.py.

    def astxt(self):
        s = ""
        if Run.showrunnr:
            s += "%*s %*s  " % (4, self.lb, 4, self.lbend())
        s += ("r" if self.isRejectedCurrentLB else "a")
        if Run.showtime:
            s += "%*s  " % (_fW['Time'],'')
        if Run.showduration:
            s += "            "
        for k in Run.SortedShowOrder():
            k = k.ResultKey
            w = 10
            if k in _fW:
                w = _fW[k]
            v=""
            if self.data_current_lb[k]:
                v = [x.value for x in self.data_current_lb[k]][0]
                if v is None:
                    v=""
            if k == "#Events" or k[0:4] == "STR:" or k=="TriggerMenu" or k=="TriggerRates" or k=="olc:bcidmask":
                v = ""
            s += "%*s  " % (w,v)
        return s
 
 
@total_ordering

◆ getLBRanges()

python.AtlRunQueryRun.RunData.getLBRanges	(		self,
			activeOnly = False )

Definition at line 251 of file AtlRunQueryRun.py.

    def getLBRanges(self,activeOnly=False):
        last_lb = self.__run_o.nr_lb
        a = [(int(data.lb),not data.isRejectedCurrentLB) for data in self if data.lb<=last_lb]
        #a = [(int(data.lb),not data.isRejectedCurrentLB) for data in self]
        if not a:
            return []
        start,state = a[0]
        ranges = []
        for x in a[:-1]:
            if x[1] == state:
                continue
            ranges += [(state, start, x[0])]
            start,state = x
        last_start,last_state = a[-1]
        if last_state==state:
            ranges += [(state, start, last_lb+1)]
        else:
            ranges += [(state, start, last_start)]
            ranges += [(last_state, last_start, last_lb+1)]
        if activeOnly:
            return [x for x in ranges if x[0]]
        else:
            return ranges
 

◆ isDQDefectRejected()

python.AtlRunQueryRun.RunData.isDQDefectRejected ( self )

Definition at line 218 of file AtlRunQueryRun.py.

    def isDQDefectRejected(self):
        if 'DQ' not in self.data_current_lb:
            return False
        return not RunData.DefectSelector(self.data_current_lb['DQ'])
 
 

◆ isDQRejected()

python.AtlRunQueryRun.RunData.isDQRejected ( self )

Definition at line 203 of file AtlRunQueryRun.py.

    def isDQRejected(self):
        for orGroup in RunData.DQLogic:
            groupAccept = False
            for k in orGroup:
                if len(self.data_current_lb[k])==0:
                    passes = False
                else:
                    passes = not self.data_current_lb[k][0].rejected
                if passes:
                    groupAccept = True
                    break
            if not groupAccept:
                return True
        return False
 

◆ isReady()

python.AtlRunQueryRun.RunData.isReady	(		self,
			lb = None )

Definition at line 232 of file AtlRunQueryRun.py.

    def isReady(self,lb=None):
        if 'Ready for physics' not in self:
            raise RuntimeError("No ready data available")
        readydata = [x for x in self.data['Ready for physics'] if x.value=='1']
        if lb is None:
            return readydata
        if type(lb)==int:
            for x in readydata:
                if x.contains(lb):
                    return True
            return False
        if type(lb)==tuple and len(lb)==2:
            for x in readydata:
                if x.intersects(lb):
                    return True
            return False
        raise RuntimeError("Can't interpret lb to check isReady(lb=%r)" % lb)
            
        

◆ isRejected()

python.AtlRunQueryRun.RunData.isRejected ( self )

Definition at line 225 of file AtlRunQueryRun.py.

    def isRejected(self):
        for s in self:
            if not s.isRejectedCurrentLB:
                return False
        return True
 
 

◆ isRejectedCurrentLB()

python.AtlRunQueryRun.RunData.isRejectedCurrentLB ( self )

Definition at line 184 of file AtlRunQueryRun.py.

    def isRejectedCurrentLB(self):
        #print ("Checking Reject for LB",self.lb,"-",self.lbend())
        need_dq_check = False
        for k,s in self.data_current_lb.items():
            if k in RunData.DQKeys:
                need_dq_check = True
                continue # exclude DQ from this, since it gets its own treatment
            if s is None:
                continue
            for e in s:
                if e.rejected:
                    return True
        if need_dq_check:
            if self.isDQRejected():
                return True
        if self.isDQDefectRejected():
            return True
        return False
 

◆ keys()

python.AtlRunQueryRun.RunData.keys ( self )

Definition at line 159 of file AtlRunQueryRun.py.

    def keys(self):
        return self.data.keys()
 

◆ lb()

python.AtlRunQueryRun.RunData.lb ( self )

Definition at line 167 of file AtlRunQueryRun.py.

    def lb(self):
        return self.current_lb
 

◆ lbend()

python.AtlRunQueryRun.RunData.lbend	(		self,
			lb = None )

Definition at line 170 of file AtlRunQueryRun.py.

    def lbend(self,lb=None):
        if lb is None:
            lb=self.current_lb
        return self.stops[self.stops.index(lb)+1]-1
 

◆ NrLBs()

python.AtlRunQueryRun.RunData.NrLBs ( self )

Definition at line 176 of file AtlRunQueryRun.py.

    def NrLBs(self):
        return "%i" % max([el.lastlb for el in self.data.values()])
 

◆ result()

python.AtlRunQueryRun.RunData.result ( self )

Definition at line 180 of file AtlRunQueryRun.py.

    def result(self):
        return self.data_current_lb
 

◆ runNrS()

python.AtlRunQueryRun.RunData.runNrS ( self )

Definition at line 163 of file AtlRunQueryRun.py.

    def runNrS(self):
        return str(self.run)
 

Member Data Documentation

◆ __run_o

python.AtlRunQueryRun.RunData.__run_o = run

private

Definition at line 127 of file AtlRunQueryRun.py.

◆ current_lb

int python.AtlRunQueryRun.RunData.current_lb = 0

Definition at line 131 of file AtlRunQueryRun.py.

◆ data

dict python.AtlRunQueryRun.RunData.data = {}

Definition at line 129 of file AtlRunQueryRun.py.

◆ data_current_lb

dict python.AtlRunQueryRun.RunData.data_current_lb = {}

Definition at line 130 of file AtlRunQueryRun.py.

◆ DefectSelector

python.AtlRunQueryRun.RunData.DefectSelector = None

static

Definition at line 124 of file AtlRunQueryRun.py.

◆ DQKeys

list python.AtlRunQueryRun.RunData.DQKeys = []

static

Definition at line 122 of file AtlRunQueryRun.py.

◆ DQLogic

list python.AtlRunQueryRun.RunData.DQLogic = []

static

Definition at line 123 of file AtlRunQueryRun.py.

◆ run

python.AtlRunQueryRun.RunData.run = run.runNr

Definition at line 128 of file AtlRunQueryRun.py.

◆ stops

list python.AtlRunQueryRun.RunData.stops = []

Definition at line 132 of file AtlRunQueryRun.py.

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

AtlRunQueryRun.py

Public Member Functions

Public Attributes

Static Public Attributes

Protected Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __init__()

Member Function Documentation

◆ __contains__()

◆ __getitem__()

◆ __iter__()

◆ __setitem__()

◆ _calcStops()

◆ _setLB()

◆ addResult()

◆ astxt()

◆ getLBRanges()

◆ isDQDefectRejected()

◆ isDQRejected()

◆ isReady()

◆ isRejected()

◆ isRejectedCurrentLB()

◆ keys()

◆ lb()

◆ lbend()

◆ NrLBs()

◆ result()

◆ runNrS()

Member Data Documentation

◆ __run_o

◆ current_lb

◆ data

◆ data_current_lb

◆ DefectSelector

◆ DQKeys

◆ DQLogic

◆ run

◆ stops

◆ init()

◆ contains()

◆ getitem()

◆ iter()

◆ setitem()