readDataHeader.ReadDataHeaderAlg Class Reference

Inheritance diagram for readDataHeader.ReadDataHeaderAlg:

Collaboration diagram for readDataHeader.ReadDataHeaderAlg:

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

Public Attributes
	totalEvents = totalEvents
int	nevt = 0
	sg = py_svc('StoreGateSvc')

Detailed Description

Definition at line 9 of file readDataHeader.py.

Constructor & Destructor Documentation

__init__()

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

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

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

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

int readDataHeader.ReadDataHeaderAlg.nevt = 0

Definition at line 14 of file readDataHeader.py.

sg

readDataHeader.ReadDataHeaderAlg.sg = py_svc('StoreGateSvc')

Definition at line 18 of file readDataHeader.py.

totalEvents

readDataHeader.ReadDataHeaderAlg.totalEvents = totalEvents

Definition at line 13 of file readDataHeader.py.

---

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

• readDataHeader.py