python.subdetectors.afp.DCSC_Merged_Variable Class Reference

Inheritance diagram for python.subdetectors.afp.DCSC_Merged_Variable:

Collaboration diagram for python.subdetectors.afp.DCSC_Merged_Variable:

Public Member Functions
def	__init__ (self, folders, evaluator, *mapping={}, **kwargs)
def	get_variable (self, name)
def	read (self, query_range, folder_base, folder_names)
def	merge_input_variables (self, *inputs)
def	merge_inputs (self, clazz, channel, *inputs)

Public Attributes
	folder_names
	mapping

Detailed Description

Definition at line 33 of file afp.py.

Constructor & Destructor Documentation

__init__()

def python.subdetectors.afp.DCSC_Merged_Variable.__init__	(		self,
			folders,
			evaluator,
		*	mapping = {},
		**	kwargs
	)

Definition at line 34 of file afp.py.

    def __init__(self, folders, evaluator, *, mapping={}, **kwargs):
        folder_merge = ','.join(folders)
            
        super().__init__(folder_merge, evaluator, **kwargs)
        self.folder_names = folders
        self.mapping = mapping
    

Member Function Documentation

get_variable()

def python.subdetectors.afp.DCSC_Merged_Variable.get_variable	(		self,
			name
	)

Definition at line 41 of file afp.py.

    def get_variable(self, name):
        for var in self.variables:
            if var.folder_name == name:
                return var
        raise RuntimeError("Folder '%s' not found" % name)
 

merge_input_variables()

def python.subdetectors.afp.DCSC_Merged_Variable.merge_input_variables	(		self,
		*	inputs
	)

Definition at line 69 of file afp.py.

    def merge_input_variables(self, *inputs):
        type_bases = [iovs.iov_type for iovs in inputs]
        base_names = [base.__name__[:-4] for base in type_bases]
        attributes = [base.lower() for base in base_names]
        clazz = make_iov_type('MERGER_OF_' + '_AND_'.join(base_names), tuple(['channel'] + attributes))
 
        inputs_by_channel = [iovs.by_channel for iovs in inputs]
        all_channels = sorted(set(y for x in inputs_by_channel for y in x.keys()))
 
        result = []
        for channel in all_channels:
            c_inputs = [x[channel] for x in inputs_by_channel]
            result.extend(iov for iov in self.merge_inputs(clazz, channel, *c_inputs))
 
        return IOVSet(result, iov_type=clazz, origin=self.folder_names)
 

merge_inputs()

def python.subdetectors.afp.DCSC_Merged_Variable.merge_inputs	(		self,
			clazz,
			channel,
		*	inputs
	)

Definition at line 85 of file afp.py.

    def merge_inputs(self, clazz, channel, *inputs):
        result = [clazz(since, until, channel, *states) for since, until, states in process_iovs(*inputs)]
        return IOVSet(result, iov_type=clazz, origin=self.folder_names)
 
@define_iov_type

read()

def python.subdetectors.afp.DCSC_Merged_Variable.read	(		self,
			query_range,
			folder_base,
			folder_names
	)

Definition at line 47 of file afp.py.

    def read(self, query_range, folder_base, folder_names):
        var_iovs = []
        folders = folder_names.split(',')
 
        for folder in folders:
            iovs = super().read(query_range, folder_base, folder)
            if folder in self.mapping:
                iovs = map_channels(iovs, self.mapping[folder], folder)
            var_iovs.append(iovs)
 
        iovs = self.merge_input_variables(*var_iovs)
 
        if config.opts.check_input_time:
            self.print_time_info(iovs)
            
        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
 

Member Data Documentation

folder_names

python.subdetectors.afp.DCSC_Merged_Variable.folder_names

Definition at line 38 of file afp.py.

mapping

python.subdetectors.afp.DCSC_Merged_Variable.mapping

Definition at line 39 of file afp.py.

---

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

• afp.py