EventGUIDLookup_Skeleton Namespace Reference

Functions
	_getRunArg (runArgs, base)
	_unwrap (a)
	_loadEventList (path)
	fromRunArgs (runArgs)

Variables
	msglog = logging.getLogger('EventGUIDLookup_Skeleton')

Detailed Description

EventGUIDLookup_Skeleton.py

Function Documentation

_getRunArg()

_getRunArg ( runArgs, base )

protected

Definition at line 13 of file EventGUIDLookup_Skeleton.py.

def _getRunArg(runArgs, base):
    attrs = vars(runArgs)
    candidates = [a for a in attrs if a == base or a.startswith(base)]
    if not candidates:
        raise AttributeError('No runArgs attribute starting with %r (have: %s)'
                              % (base, sorted(attrs.keys())))
    candidates.sort(key=lambda a: (a != base, len(a)))
    return getattr(runArgs, candidates[0])
 
 

_loadEventList()

_loadEventList ( path )

protected

Definition at line 29 of file EventGUIDLookup_Skeleton.py.

def _loadEventList(path):
    requested = set()
    with open(path) as fh:
        for lineNo, line in enumerate(fh, 1):
            line = line.strip()
            if not line or line.startswith('#'):
                continue
            fields = line.split()
            if len(fields) < 2:
                msglog.warning('Ignoring malformed line %d in %s: %r',
                                lineNo, path, line)
                continue
            requested.add((int(fields[0]), int(fields[1])))
    return requested
 
 

_unwrap()

_unwrap ( a )

protected

Definition at line 23 of file EventGUIDLookup_Skeleton.py.

def _unwrap(a):
    if hasattr(a, 'value'):
        a = a.value
    return a if isinstance(a, list) else [a]
 
 

fromRunArgs()

fromRunArgs

(

runArgs

)

Definition at line 45 of file EventGUIDLookup_Skeleton.py.

def fromRunArgs(runArgs):
    msglog.info('***************** STARTING EventGUIDLookup *****************')
 
    dataType = runArgs.dataType
    inputDataType = runArgs.inputDataType
    eventListPath = runArgs.eventList
    inputFiles = [str(f) for f in _unwrap(_getRunArg(runArgs, 'inputFile'))]
    outputPath = _unwrap(_getRunArg(runArgs, 'outputTXTFile'))[0]
 
    requested = _loadEventList(eventListPath)
    msglog.info('Loaded %d requested (run,event) pairs', len(requested))
 
    flags = initConfigFlags()
    flags.Input.Files = inputFiles
    flags.Exec.MaxEvents = -1
    flags.Concurrency.NumThreads = 1
    flags.lock()
 
    cfg = MainServicesCfg(flags)
 
    from AthenaPoolCnvSvc.PoolReadConfig import PoolReadCfg
    cfg.merge(PoolReadCfg(flags))
    # (xAODEventInfoCnvAlgDefault import removed -- not needed, and not
    # verified to exist at that path anyway)
 
    from EventGUIDLookup.EventGUIDLookupAlgConfig import EventGUIDLookupAlgCfg
    cfg.merge(EventGUIDLookupAlgCfg(flags, dataType=dataType,
                                     inputDataType=inputDataType,
                                     requestedEvents=requested,
                                     outputFile=outputPath))
 
    sc = cfg.run()
    sys.exit(0 if sc.isSuccess() else 1)

Variable Documentation

msglog

EventGUIDLookup_Skeleton.msglog = logging.getLogger('EventGUIDLookup_Skeleton')

Definition at line 10 of file EventGUIDLookup_Skeleton.py.