EventGUIDLookupLib Namespace Reference

Functions
	_streamKey (dataType)
	guid2string (guid)
	token2string (tk, replace_empty_cntID=False)
	_resolveAncestorProvenance (dh, requestedKey)
	_resolveSelfReference (dh, requestedKey)
	resolveProvenanceGuid (store, dataType, inputDataType)

Variables
	_TOKEN_DB_RE
dict	_STREAM_KEY
tuple	_KNOWN_ANCESTOR_KEYS

Detailed Description

EventGUIDLookupLib.py

Provenance GUID resolution, adapted from the "Self reference and
Provenance" block of
  Database/EventIndex/EventIndexProducer/python/POOL2EI_Lib.py

- If the requested dataType IS the input file's own dataType, the GUID
  is in the *self reference* (the current file's own DataHeader entry).
- Otherwise, the GUID is in the *ancestor provenance* record for that
  stream, and only exists at all for the handful of streams POOL2EI_Lib
  recognizes there (RAW/ESD/AOD/RDO/HITS/EVGEN/Embedding) -- see
  _KNOWN_ANCESTOR_KEYS.

Function Documentation

_resolveAncestorProvenance()

_resolveAncestorProvenance ( dh, requestedKey )

protected

Definition at line 63 of file EventGUIDLookupLib.py.

def _resolveAncestorProvenance(dh, requestedKey):
    if dh.sizeProvenance() == 0:
        return None
    guid = None
    prv = dh.beginProvenance()
    for _ in range(dh.sizeProvenance()):
        key = prv.getKey()
        if key.startswith("Output"):
            key = key[6:]
        if key.startswith("Input"):
            key = key[5:]
        if key in _KNOWN_ANCESTOR_KEYS and key == requestedKey and guid is None:
            tk = prv.getToken()
            stk = token2string(tk, replace_empty_cntID=(key != 'StreamRAW'))
            m = _TOKEN_DB_RE.search(stk)
            if m:
                guid = m.group(1)
            del tk
        del key
        prv += 1
    del prv
    return guid
 
 

_resolveSelfReference()

_resolveSelfReference ( dh, requestedKey )

protected

Definition at line 87 of file EventGUIDLookupLib.py.

def _resolveSelfReference(dh, requestedKey):
    if dh.size() == 0:
        return None
    guid = None
    dhe = dh.begin()
    for _ in range(dh.size()):
        key = dhe.getKey()
        if key == requestedKey and guid is None:
            tk = dhe.getToken()
            stk = token2string(tk, replace_empty_cntID=True)
            m = _TOKEN_DB_RE.search(stk)
            if m:
                guid = m.group(1)
            del tk
        del key
        dhe += 1
    dh.end()
    return guid
 
 

_streamKey()

_streamKey ( dataType )

protected

Map --dataType/--inputDataType onto the DataHeader key. Types with
no fixed internal name (DAOD_PHYS, DAOD_PHYSLITE) fall back to
'Stream<dataType>' -- only usable as a self-reference, never as a
recognized ancestor key (see _KNOWN_ANCESTOR_KEYS).

Definition at line 37 of file EventGUIDLookupLib.py.

def _streamKey(dataType):
    """Map --dataType/--inputDataType onto the DataHeader key. Types with
    no fixed internal name (DAOD_PHYS, DAOD_PHYSLITE) fall back to
    'Stream<dataType>' -- only usable as a self-reference, never as a
    recognized ancestor key (see _KNOWN_ANCESTOR_KEYS)."""
    return _STREAM_KEY.get(dataType, 'Stream' + dataType)
 
 

guid2string()

guid2string

(

guid

)

Definition at line 45 of file EventGUIDLookupLib.py.

def guid2string(guid):
    return "{:08X}-{:04X}-{:04X}-{:02X}{:02X}-{:02X}{:02X}{:02X}{:02X}{:02X}{:02X}".format(
        guid.data1(), guid.data2(), guid.data3(),
        ord(guid.data4(0)[0]), ord(guid.data4(1)[0]),
        ord(guid.data4(2)[0]), ord(guid.data4(3)[0]),
        ord(guid.data4(4)[0]), ord(guid.data4(5)[0]),
        ord(guid.data4(6)[0]), ord(guid.data4(7)[0]))
 
 

resolveProvenanceGuid()

resolveProvenanceGuid	(		store,
			dataType,
			inputDataType )

Return the provenance GUID string for `dataType`, given the input
file is actually `inputDataType`, for the current event -- call from
inside an algorithm's execute(). Returns None if not found.

Definition at line 107 of file EventGUIDLookupLib.py.

def resolveProvenanceGuid(store, dataType, inputDataType):
    """Return the provenance GUID string for `dataType`, given the input
    file is actually `inputDataType`, for the current event -- call from
    inside an algorithm's execute(). Returns None if not found."""
 
    dh = store.retrieve('DataHeader', 'EventSelector')
    requestedKey = _streamKey(dataType)
 
    if dataType == inputDataType:
        return _resolveSelfReference(dh, requestedKey)
    else:
        return _resolveAncestorProvenance(dh, requestedKey)

token2string()

token2string	(		tk,
			replace_empty_cntID = False )

Definition at line 54 of file EventGUIDLookupLib.py.

def token2string(tk, replace_empty_cntID=False):
    cntID = tk.contID()
    if replace_empty_cntID and cntID == "":
        cntID = "POOLContainer(DataHeader)"
    return "[DB={}][CNT={}][CLID={}][TECH={:08X}][OID={:016X}-{:016X}]".format(
        guid2string(tk.dbID()), cntID, guid2string(tk.classID()),
        tk.technology(), tk.oid().first, tk.oid().second)
 
 

Variable Documentation

_KNOWN_ANCESTOR_KEYS

tuple EventGUIDLookupLib._KNOWN_ANCESTOR_KEYS

protected

Initial value:

=  ('StreamRAW', 'StreamAOD', 'StreamESD', 'StreamRDO',
                         'StreamHITS', 'StreamEVGEN', 'EmbeddingStream')

Definition at line 33 of file EventGUIDLookupLib.py.

_STREAM_KEY

dict EventGUIDLookupLib._STREAM_KEY

protected

Initial value:

=  {
    'RAW': 'StreamRAW',
    'ESD': 'StreamESD',
    'AOD': 'StreamAOD',
    'RDO': 'StreamRDO',
    'HITS': 'StreamHITS',
    'EVNT': 'StreamEVGEN',
}

Definition at line 24 of file EventGUIDLookupLib.py.

_TOKEN_DB_RE

EventGUIDLookupLib._TOKEN_DB_RE

protected

Initial value:

=  re.compile(r'\‍[DB=([0-9A-Fa-f]{8}-[0-9A-Fa-f]{4}-'
                           r'[0-9A-Fa-f]{4}-[0-9A-Fa-f]{4}-[0-9A-Fa-f]{12})\‍]')

Definition at line 20 of file EventGUIDLookupLib.py.