python.subdetectors.afp.TDAQC_Multi_Channel_Variable Class Reference

Inheritance diagram for python.subdetectors.afp.TDAQC_Multi_Channel_Variable:

Collaboration diagram for python.subdetectors.afp.TDAQC_Multi_Channel_Variable:

Public Member Functions
def	make_good_iov (self, iov)
def	make_good_iovs (self, iovs)
def	__repr__ (self)
def	read (self, query_range, query, *regex=False)
def	calculate_good_iovs (self, lbtime, subdetector)

Static Public Member Functions
def	timeCOOL2PBeast (timestamp)
def	timePBeast2COOL (timestamp)

Public Attributes
	regex
	mapping
	force_mapping
	empty_value
	query
	path
	input_hashes
	subdetector
	iovs

Static Public Attributes
int	TIME_RATIO = 1e3

Detailed Description

Definition at line 205 of file afp.py.

Member Function Documentation

__repr__()

def python.subdetectors.afp.TDAQC_Variable.__repr__ (   self )

inherited

Definition at line 117 of file afp.py.

    def __repr__(self):
        return f"<TDAQCVariable {self.query}>"
    

calculate_good_iovs()

def python.subdetectors.afp.TDAQC_Variable.calculate_good_iovs (   self,   lbtime,   subdetector  )

inherited

Calculate LB-wise "good" states

Definition at line 166 of file afp.py.

    def calculate_good_iovs(self, lbtime, subdetector):
        """
        Calculate LB-wise "good" states
        """
 
        self.subdetector = subdetector
        
        since, until = lbtime.first, lbtime.last
        if self.timewise_folder:
            query_range = RANGEIOV_VAL(since.since, until.until)
        else:
            query_range = RANGEIOV_VAL(RunLumi(since.Run, since.LumiBlock), 
                                       RunLumi(until.Run, until.LumiBlock))
        
        # Read the database
        iovs = self.read(query_range, self.query, regex=self.regex)
        # Decide the states of the input iovs
        iovs = self.make_good_iovs(iovs)
        # Apply a mapping for input channels if necessary
        iovs = self.map_input_channels(iovs)
 
        if self.timewise_folder and not config.opts.timewise:
            # we might already know the defect mapping
            with timer("Quantize %s (%i iovs over %i lbs)" % 
                       (self.query, len(iovs), len(lbtime))):
                # Quantize to luminosity block
                iovs = self.quantize(lbtime, iovs)
 
        self.iovs = iovs
        return self
 

make_good_iov()

def python.subdetectors.afp.TDAQC_Multi_Channel_Variable.make_good_iov	(		self,
			iov
	)

Determine if channels in one input iov are good.

Reimplemented from python.subdetectors.afp.TDAQC_Variable.

Reimplemented in python.subdetectors.afp.TDAQC_Array_Variable, and python.subdetectors.afp.TDAQC_Bit_Flag_Variable.

Definition at line 206 of file afp.py.

    def make_good_iov(self, iov):
        """
        Determine if channels in one input iov are good.
        """
        giov = []
        for channel, goodness in self.evaluator(iov):
            current = GoodIOV(iov.since, iov.until, channel, goodness)
            current._orig_iov = iov
            giov.append(current)
        return giov
    

make_good_iovs()

def python.subdetectors.afp.TDAQC_Multi_Channel_Variable.make_good_iovs	(		self,
			iovs
	)

Determine whether each iov signifies a good or bad state.

Definition at line 217 of file afp.py.

    def make_good_iovs(self, iovs):
        """
        Determine whether each iov signifies a good or bad state.
        """
        results = []
        for iov in iovs:
            results.append(self.make_good_iov(iov))
        return IOVSet(sum(zip(*results), ())) # Sort by channel first
 

read()

def python.subdetectors.afp.TDAQC_Variable.read (   self,   query_range,   query, *  regex = False  )

inherited

Read the relevant data from pBeast for this variable, and convert them to COOL-like format

Definition at line 120 of file afp.py.

    def read(self, query_range, query, *, regex=False):
        """
        Read the relevant data from pBeast for this variable, and convert them to COOL-like format
        """
        partition, className, attribute, path = query.split('.', 3)
        
        log.info(f"Querying pBeast object{'s using regex' if regex else ''} {query}")
 
        since, until = query_range
        since, until = TDAQC_Variable.timeCOOL2PBeast(since), TDAQC_Variable.timeCOOL2PBeast(until)
        
        query_data = pbeast.get_data(partition, className, attribute, path, regex, since, until)
        data = dict.fromkeys(self.mapping.keys()) if self.force_mapping else dict()
        if query_data:
            data.update(query_data[0].data)
 
        def instantiate(since, until, channel, value):
            if isinstance(value, list):
                value = tuple(value)
            return PBeastIOV(TDAQC_Variable.timePBeast2COOL(since), TDAQC_Variable.timePBeast2COOL(until), channel, value)
 
        iovs = []
        for channel, entries in data.items():
            if not entries:
                iovs.append(PBeastIOV(*query_range, channel, self.empty_value))
                continue
            first = entries[0]
            since = first.ts
            value = first.value
            for point in entries:
                if point.value == value:
                    continue
                iovs.append(instantiate(since, point.ts, channel, value))
                since = point.ts
                value = point.value
            last = entries[-1]
            iovs.append(instantiate(since, last.ts, channel, value))
        iovs = IOVSet(iovs, iov_type=PBeastIOV, origin=query)
            
        if log.isEnabledFor(logging.INFO):
            input_hash = hash(iovs)
            self.input_hashes.append(input_hash)
            log.info("  -> Input hash: % 09x (len=%i)", input_hash, len(iovs))
            
        return iovs
 

timeCOOL2PBeast()

def python.subdetectors.afp.TDAQC_Variable.timeCOOL2PBeast (   timestamp )

staticinherited

Definition at line 100 of file afp.py.

    def timeCOOL2PBeast(timestamp):
        return int(timestamp/TDAQC_Variable.TIME_RATIO)
    

timePBeast2COOL()

def python.subdetectors.afp.TDAQC_Variable.timePBeast2COOL (   timestamp )

staticinherited

Definition at line 104 of file afp.py.

    def timePBeast2COOL(timestamp):
        return TimestampType(timestamp*TDAQC_Variable.TIME_RATIO)
 

Member Data Documentation

empty_value

python.subdetectors.afp.TDAQC_Variable.empty_value

inherited

Definition at line 112 of file afp.py.

force_mapping

python.subdetectors.afp.TDAQC_Variable.force_mapping

inherited

Definition at line 111 of file afp.py.

input_hashes

python.subdetectors.afp.TDAQC_Variable.input_hashes

inherited

Definition at line 115 of file afp.py.

iovs

python.subdetectors.afp.TDAQC_Variable.iovs

inherited

Definition at line 194 of file afp.py.

mapping

python.subdetectors.afp.TDAQC_Variable.mapping

inherited

Definition at line 110 of file afp.py.

path

python.subdetectors.afp.TDAQC_Variable.path

inherited

Definition at line 114 of file afp.py.

query

python.subdetectors.afp.TDAQC_Variable.query

inherited

Definition at line 113 of file afp.py.

regex

python.subdetectors.afp.TDAQC_Variable.regex

inherited

Definition at line 109 of file afp.py.

subdetector

python.subdetectors.afp.TDAQC_Variable.subdetector

inherited

Definition at line 171 of file afp.py.

TIME_RATIO

int python.subdetectors.afp.TDAQC_Variable.TIME_RATIO = 1e3

staticinherited

Definition at line 97 of file afp.py.

---

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

• afp.py