python.DQUtilities.IDBSDefectData Class Reference

Collaboration diagram for python.DQUtilities.IDBSDefectData:

Public Member Functions
def	__init__ (self, database='COOLOFL_GLOBAL/CONDBR2', tag='HEAD', debug=False)
def	__del__ (self)
def	connect (self)
def	defectList (self)
def	defect (self, run, lb, channels=None)
def	defectsRange (self, run, lbStart, lbEnd, channels=None)
def	dumpRun (self, run, channels=None)

Public Attributes
	db
	idbsDefects

Static Public Attributes
list	defectBitPos
	database
	tag
	lastRun
	iovsets
	debug

Private Member Functions
def	_defectForLB (self, lb)

Detailed Description

Container for beamspot DQ defects from COOL

Definition at line 196 of file DQUtilities.py.

Constructor & Destructor Documentation

__init__()

def python.DQUtilities.IDBSDefectData.__init__	(		self,
			database = 'COOLOFL_GLOBAL/CONDBR2',
			tag = 'HEAD',
			debug = False
	)

Definition at line 205 of file DQUtilities.py.

    def __init__(self, database='COOLOFL_GLOBAL/CONDBR2', tag='HEAD', debug=False):

__del__()

def python.DQUtilities.IDBSDefectData.__del__

(

self

)

Delete db to clear connection

Definition at line 221 of file DQUtilities.py.

    def __del__(self):
        """
        Delete db to clear connection
        """
 
        del self.db
        pass
 
 

Member Function Documentation

_defectForLB()

def python.DQUtilities.IDBSDefectData._defectForLB (   self,   lb  )

private

Get the DQ defects for the given LB from the full run info

Definition at line 298 of file DQUtilities.py.

    def _defectForLB(self, lb):
        """
        Get the DQ defects for the given LB from the full run info
        """
 
        defects = []
        for since, until, states in process_iovs(*self.iovsets):
            if since.lumi <= lb < until.lumi:
                # defects is true if set for a given run/LB
                defects = [state.channel for state in states if state]
 
        return list(set(defects))
        
    

connect()

def python.DQUtilities.IDBSDefectData.connect

(

self

)

Open connection to defect DB

Definition at line 230 of file DQUtilities.py.

    def connect(self):
        """
        Open connection to defect DB
        """
 
        self.db = DefectsDB(self.database, read_only=True, create=False, tag=self.tag)
        self.idbsDefects = [d for d in self.db.defect_names if d.startswith('ID_BS_') or d == 'LUMI_VDM']
 
        if self.debug:
            print (self.idbsDefects)
 
        return
 

defect()

def python.DQUtilities.IDBSDefectData.defect	(		self,
			run,
			lb,
			channels = None
	)

Get list of DQ defects for a particular run and lb, caching the result for the latest (succesful) run
e.g.
 from InDetBeamSpotExample.DQUtilities import IDBSDefectData
 idbs = IDBSDefectData()
 idbs.defect(167661,372)

channels is the list of defects to look for (defaults to all ID_BS defects)

Definition at line 250 of file DQUtilities.py.

    def defect(self, run, lb, channels=None):
        """
        Get list of DQ defects for a particular run and lb, caching the result for the latest (succesful) run
        e.g.
                 from InDetBeamSpotExample.DQUtilities import IDBSDefectData
                 idbs = IDBSDefectData()
                 idbs.defect(167661,372)
 
        channels is the list of defects to look for (defaults to all ID_BS defects)
        """
 
        if channels is None:
            channels = self.idbsDefects
 
        # Encode start and end of run
        lbMin = 0
        lbMax = (1 << 32)-1
        since = (run << 32)+lbMin
        until = (run << 32)+lbMax
 
        # If the run is the same at the previous one return defects from cache
        if run == self.lastRun:
            defects = self._defectForLB(lb)
            if self.debug:
                print (run, lb, defects)
            return defects
 
        # Retrive info for entire run
        iovs = self.db.retrieve(since, until, channels=channels)
 
        # Check if run exists
        if not iovs:
             print ("Unable to access folder with given parameters")
             return []
 
        # If found, update last run and get list of IOVSets for each defect/channel
        self.lastRun = run        
        chans, self.iovsets = iovs.chans_iovsets
 
        defects = self._defectForLB(lb)
 
        # Debug
        if self.debug:
            iovs.pprint()
            print (run, lb, defects)
        
        return defects
 

defectList()

def python.DQUtilities.IDBSDefectData.defectList

(

self

)

List of all possible beamspot defects

Definition at line 243 of file DQUtilities.py.

    def defectList(self):
        """
        List of all possible beamspot defects
        """
 
        return self.idbsDefects
 

defectsRange()

def python.DQUtilities.IDBSDefectData.defectsRange	(		self,
			run,
			lbStart,
			lbEnd,
			channels = None
	)

Return the maximal list of defects for a given range. lbEnd is exclusive

Definition at line 312 of file DQUtilities.py.

    def defectsRange(self, run, lbStart, lbEnd, channels=None):
        """
        Return the maximal list of defects for a given range. lbEnd is exclusive
        """
 
        defects = []
        for lb in range(lbStart, lbEnd):
            defects.extend(self.defect(run, lb, channels=channels))
 
        return list(set(defects))
 

dumpRun()

def python.DQUtilities.IDBSDefectData.dumpRun	(		self,
			run,
			channels = None
	)

Dump DQ info for a particular run (useful in reprocessing to compare new to old)

Definition at line 323 of file DQUtilities.py.

    def dumpRun(self, run, channels=None):
        """
        Dump DQ info for a particular run (useful in reprocessing to compare new to old)
        """
 
        if channels is None:
            channels = self.idbsDefects
            
        # Encode start and end of run
        lbMin = 0
        lbMax = (1 << 32)-1
        since = (run << 32)+lbMin
        until = (run << 32)+lbMax
        
        # Retrive info for entire run
        iovs = self.db.retrieve(since, until, channels=channels, nonpresent=True)
        
        # Check if run exists
        if not iovs:
            print ("Unable to access folder with given parameters")
            return []
 
        iovs.pprint()
 
        return
 

Member Data Documentation

database

python.DQUtilities.IDBSDefectData.database

static

Initialise database connection 

Definition at line 211 of file DQUtilities.py.

db

python.DQUtilities.IDBSDefectData.db

Definition at line 235 of file DQUtilities.py.

debug

python.DQUtilities.IDBSDefectData.debug

static

Definition at line 215 of file DQUtilities.py.

defectBitPos

list python.DQUtilities.IDBSDefectData.defectBitPos

static

Initial value:

=  ['UNKNOWN', 'ID_BS_2010YELLOW', 'ID_BS_RUNAVERAGE', 'ID_BS_PARAMETERSTEP',
                      'ID_BS_NOBEAMSPOT', 'ID_BS_2010RED', 'LUMI_VDM']

Definition at line 201 of file DQUtilities.py.

idbsDefects

python.DQUtilities.IDBSDefectData.idbsDefects

Definition at line 236 of file DQUtilities.py.

iovsets

python.DQUtilities.IDBSDefectData.iovsets

static

Definition at line 214 of file DQUtilities.py.

lastRun

python.DQUtilities.IDBSDefectData.lastRun

static

Definition at line 213 of file DQUtilities.py.

tag

python.DQUtilities.IDBSDefectData.tag

static

Definition at line 212 of file DQUtilities.py.

---

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

• DQUtilities.py