Collaboration diagram for python.DQUtilities.IDBSDefectData:

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

Public Attributes
	db = DefectsDB(self.database, read_only=True, create=False, tag=self.tag)
list	idbsDefects = [d for d in self.db.defect_names if d.startswith('ID_BS_') or d == 'LUMI_VDM']

Static Public Attributes
list	defectBitPos
	database
	tag
	lastRun
	iovsets
	debug

Protected Member Functions
	_defectForLB (self, lb)

Detailed Description

Container for beamspot DQ defects from COOL

Definition at line 196 of file DQUtilities.py.

Constructor & Destructor Documentation

◆ init()

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

Definition at line 205 of file DQUtilities.py.

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

◆ del()

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()

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

protected

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()

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()

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
 
        # Retrieve 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()

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()

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()

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
        
        # Retrieve 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 = DefectsDB(self.database, read_only=True, create=False, tag=self.tag)

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 = [d for d in self.db.defect_names if d.startswith('ID_BS_') or d == 'LUMI_VDM']

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

Public Member Functions

Public Attributes

Static Public Attributes

Protected Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ __init__()

◆ __del__()

Member Function Documentation

◆ _defectForLB()

◆ connect()

◆ defect()

◆ defectList()

◆ defectsRange()

◆ dumpRun()

Member Data Documentation

◆ database

◆ db

◆ debug

◆ defectBitPos

◆ idbsDefects

◆ iovsets

◆ lastRun

◆ tag

◆ init()

◆ del()