readDataHeader.ReadDataHeaderAlg Class Reference

Inheritance diagram for readDataHeader.ReadDataHeaderAlg:

Collaboration diagram for readDataHeader.ReadDataHeaderAlg:

Public Member Functions
def	__init__ (self, name='ReadDataHeaderAlg', totalEvents=0)
def	initialize (self)
def	execute (self)
def	finalize (self)

Public Attributes
	totalEvents
	nevt
	sg

Detailed Description

Definition at line 9 of file readDataHeader.py.

Constructor & Destructor Documentation

__init__()

def readDataHeader.ReadDataHeaderAlg.__init__	(		self,
			name = 'ReadDataHeaderAlg',
			totalEvents = 0
	)

Definition at line 11 of file readDataHeader.py.

    def __init__(self,name='ReadDataHeaderAlg', totalEvents=0):
        super(ReadDataHeaderAlg,self).__init__(name=name)
        self.totalEvents = totalEvents
        self.nevt = 0
        return
 

Member Function Documentation

execute()

def readDataHeader.ReadDataHeaderAlg.execute

(

self

)

Definition at line 21 of file readDataHeader.py.

    def execute(self):
        if self.sg.contains('DataHeader', 'EventSelector'):
            dh = self.sg.retrieve('DataHeader', 'EventSelector')
            sz = dh.size()
            self.nevt += 1
            if self.nevt % 100 == 0:
                logging.info(f'DataHeader Size {sz} in event #{self.nevt}')
            if sz > 0:
                it = dh.begin()
                for idx in range(sz):
                    logging.debug(f'  >>  Key {it.getKey()} : Token {it.getToken().toString()}')
                    it+=1
                else:
                    logging.debug('  >> Successfully read through the DataHeader')
            else:
                logging.error(f'  >> Negative DataHeader size ({sz})!')
                return StatusCode.Failure
        else:
            logging.error('Could NOT find the DataHeader!')
            return StatusCode.Failure
 
        return StatusCode.Success
 

finalize()

def readDataHeader.ReadDataHeaderAlg.finalize

(

self

)

Definition at line 44 of file readDataHeader.py.

    def finalize(self):
        # Now this hack is needed because some errors, e.g. those in loading proxies,
        # don't cause a job failure because most loop managers seem to ignore them.
        # The problem is that even though we fail here, the job still "succeeds"
        if self.nevt != self.totalEvents:
            logging.error(f'Expected {self.totalEvents} events but processed {self.nevt}!')
            logging.error('This most likely means we could not process some events successfully!')
            return StatusCode.Failure
 
        return StatusCode.Success
 
# A minimal job that reads the DataHeader

initialize()

def readDataHeader.ReadDataHeaderAlg.initialize

(

self

)

Definition at line 17 of file readDataHeader.py.

    def initialize(self):
        self.sg = py_svc('StoreGateSvc')
        return StatusCode.Success
 

Member Data Documentation

nevt

readDataHeader.ReadDataHeaderAlg.nevt

Definition at line 14 of file readDataHeader.py.

sg

readDataHeader.ReadDataHeaderAlg.sg

Definition at line 18 of file readDataHeader.py.

totalEvents

readDataHeader.ReadDataHeaderAlg.totalEvents

Definition at line 13 of file readDataHeader.py.

---

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

• readDataHeader.py