python.AtlRunQueryRun.RunData Class Reference

Collaboration diagram for python.AtlRunQueryRun.RunData:

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

Public Attributes
	run
	data
	data_current_lb
	current_lb
	stops

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

Private Member Functions
def	_setLB (self, lb)
def	_calcStops (self)

Private Attributes
	__run_o

Detailed Description

Definition at line 120 of file AtlRunQueryRun.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 127 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__()

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

Definition at line 135 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__()

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

Definition at line 140 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__()

def python.AtlRunQueryRun.RunData.__iter__

(

self

)

Definition at line 152 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__()

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

Definition at line 149 of file AtlRunQueryRun.py.

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

_calcStops()

def python.AtlRunQueryRun.RunData._calcStops (   self )

private

Definition at line 280 of file AtlRunQueryRun.py.

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

_setLB()

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

private

Definition at line 276 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()

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

Definition at line 286 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()

def python.AtlRunQueryRun.RunData.astxt

(

self

)

Definition at line 291 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()

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

Definition at line 252 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()

def python.AtlRunQueryRun.RunData.isDQDefectRejected

(

self

)

Definition at line 219 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()

def python.AtlRunQueryRun.RunData.isDQRejected

(

self

)

Definition at line 204 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()

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

Definition at line 233 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()

def python.AtlRunQueryRun.RunData.isRejected

(

self

)

Definition at line 226 of file AtlRunQueryRun.py.

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

isRejectedCurrentLB()

def python.AtlRunQueryRun.RunData.isRejectedCurrentLB

(

self

)

Definition at line 185 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()

def python.AtlRunQueryRun.RunData.keys

(

self

)

Definition at line 160 of file AtlRunQueryRun.py.

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

lb()

def python.AtlRunQueryRun.RunData.lb

(

self

)

Definition at line 168 of file AtlRunQueryRun.py.

    def lb(self):
        return self.current_lb
 

lbend()

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

Definition at line 171 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()

def python.AtlRunQueryRun.RunData.NrLBs

(

self

)

Definition at line 177 of file AtlRunQueryRun.py.

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

result()

def python.AtlRunQueryRun.RunData.result

(

self

)

Definition at line 181 of file AtlRunQueryRun.py.

    def result(self):
        return self.data_current_lb
 

runNrS()

def python.AtlRunQueryRun.RunData.runNrS

(

self

)

Definition at line 164 of file AtlRunQueryRun.py.

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

Member Data Documentation

__run_o

python.AtlRunQueryRun.RunData.__run_o

private

Definition at line 128 of file AtlRunQueryRun.py.

current_lb

python.AtlRunQueryRun.RunData.current_lb

Definition at line 132 of file AtlRunQueryRun.py.

data

python.AtlRunQueryRun.RunData.data

Definition at line 130 of file AtlRunQueryRun.py.

data_current_lb

python.AtlRunQueryRun.RunData.data_current_lb

Definition at line 131 of file AtlRunQueryRun.py.

DefectSelector

python.AtlRunQueryRun.RunData.DefectSelector = None

static

Definition at line 125 of file AtlRunQueryRun.py.

DQKeys

list python.AtlRunQueryRun.RunData.DQKeys = []

static

Definition at line 123 of file AtlRunQueryRun.py.

DQLogic

list python.AtlRunQueryRun.RunData.DQLogic = []

static

Definition at line 124 of file AtlRunQueryRun.py.

run

python.AtlRunQueryRun.RunData.run

Definition at line 129 of file AtlRunQueryRun.py.

stops

python.AtlRunQueryRun.RunData.stops

Definition at line 133 of file AtlRunQueryRun.py.

---

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

• AtlRunQueryRun.py