python.TrigIDR4MonConfig Namespace Reference

Functions
	TrigIDR4MonConfig (flags, monlevels=None)
	TrigIDR4MonitoringCA (iflags, monlevels=None)
	TrigIDR4Monitoring (flags, name=None, monlevel=None, kak=None)
	TrigIDR4MonSignature (flags, key, toolkey, tools, monlevel, kak)
	TrigIDR4Mon_builder (flags=None, name="NoName")
	createTATools (flags, label, chains, excludeTagChains=True, kak=None)
	chomp (s, suffix)
	getTagnProbe (probe, chains, cs_probe=None)
	histsvc (flags)
	file_exists (files)
	is_mc (filename)
	clean_args (values, args, cmdoption)
	parse_signatures (signatures, args=None)
	parse_files (files, args=None)

Variables
	flags = initConfigFlags()
str	file = 'AOD.pool.root'
	Files
	isMC
	HISTFileName
	doExpressProcessing
	AODFixesDone
	tflags = decodeFlags( flags )
	cfg = MainServicesCfg(tflags)
	withDetails
int	Nevents = 25000

Function Documentation

chomp()

chomp	(		s,
			suffix )

Definition at line 161 of file TrigIDR4MonConfig.py.

def chomp(s, suffix):
        if s.endswith(suffix) :  return s[:-len(suffix)] 
        else : return s
 
        

clean_args()

clean_args	(		values,
			args,
			cmdoption )

Definition at line 258 of file TrigIDR4MonConfig.py.

def clean_args( values, args, cmdoption ):
    if not args : return
    for arg in args:
        if arg.startswith(cmdoption) :
            idx = args.index(arg)
            del args[idx]
            
    for arg in values:
        if arg in args: 
            idx = args.index(arg)
            del args[idx]
 
 

createTATools()

createTATools	(		flags,
			label,
			chains,
			excludeTagChains = True,
			kak = None )

Definition at line 145 of file TrigIDR4MonConfig.py.

def createTATools( flags, label, chains, excludeTagChains=True, kak=None ):
        tools = []
 
        from TrigIDR4Monitoring.TrackAnalysisConfig import createTrackAnalysis
 
        for chain in chains :        
                cs = chainString(chain)
                if excludeTagChains and "tag" in cs.extra: continue
                # if it's a probe chain, find the correspondiong tag chain
                # and pass the pair to track analysis 
                tpchains = getTagnProbe( chain, chains, cs )
                tatool = createTrackAnalysis( flags, chain, tpchains, label, kak  )  
                tools += [ tatool ]
        return tools
 
 

file_exists()

file_exists

(

files

)

Definition at line 240 of file TrigIDR4MonConfig.py.

def file_exists( files ):
    if isinstance( files, str ): files = [ files ]
    for f in files:
        print( f"check file: {f}" )    
        # don't check xrootd files ...    
        if f.startswith(("root://","http://")): continue
        if not os.path.isfile(f):
            print(f"ERROR: Input file '{f}' does not exist, cwd: "+os.getcwd())
            sys.exit(1)
 
            

getTagnProbe()

getTagnProbe	(		probe,
			chains,
			cs_probe = None )

Definition at line 166 of file TrigIDR4MonConfig.py.

def getTagnProbe( probe, chains, cs_probe=None ) :
 
        if cs_probe is None: cs_probe = chainString(probe)
        
        if "probe" not in cs_probe.extra : return [ probe ]
        
        prefix_probe = chomp( cs_probe.extra, "_probe" )
        
        # so this is a probe chain ...
 
        #        print( "searching for tag for ", probe )
        
        for tag in chains :        
                
                #                print( "\ttag: ", tag )
                
                if tag==probe : continue
                
                cstag = chainString(tag)
 
                # in principle, should be able to use any chain as a tag, and
                # any chain as a probe, but then each extra=xxx_probe would
                # need to be unique, which would prevent using wildcared
                # tag and probe chain pairs
                
                if cs_probe.head!=cstag.head : continue
 
                # actually, for the tag and probe analysis, you don't
                # really care about the tag trigger information, only the
                # reference selection to reconstruct the tnp selection
                # criterion
 
                # if cs_probe.tail!=cstag.tail : continue
 
                if "tag" not in cstag.extra : continue
                
                prefix_tag = chomp( cstag.extra, "_tag" )
        
                if prefix_probe != prefix_tag : continue
 
                #                print( "   Fount Tnp: tag:   ", tag ) 
                #                print( "   Fount Tnp: probe: ", probe ) 
                
                return [ probe, tag ]
 
        return [ probe ]
        
                        
 
 

histsvc()

histsvc

(

flags

)

Definition at line 216 of file TrigIDR4MonConfig.py.

def histsvc( flags ):
 
    from AthenaCommon.Logging import log
 
    if flags.Output.HISTFileName: 
            log.info( "histsvc: Create THistSvc with file name: "+flags.Output.HISTFileName )
    
    from AthenaConfiguration.ComponentAccumulator import ComponentAccumulator
    ca = ComponentAccumulator()
    
    from AthenaConfiguration.ComponentFactory import CompFactory
    THistSvc = CompFactory.THistSvc
        
    histsvc = THistSvc()
    if flags.Output.HISTFileName:
        histsvc.Output += ["%s DATAFILE='%s' OPT='RECREATE'" % (flags.DQ.FileKey, flags.Output.HISTFileName)]
        log.info( "histsvc: "+histsvc.Output[-1] )
 
    ca.addService(histsvc)
 
    return ca
 
 
 

is_mc()

is_mc

(

filename

)

Definition at line 251 of file TrigIDR4MonConfig.py.

def is_mc( filename ):
    from PyUtils.MetaReader import read_metadata
    if filename.startswith(("root://","http://")): return None
    metadata = read_metadata(filename)
    return 'IS_SIMULATION' in metadata[filename].get('eventTypes', [])
 
 

parse_files()

parse_files	(		files,
			args = None )

Definition at line 283 of file TrigIDR4MonConfig.py.

def parse_files( files, args=None ) :
 
    if files is None : 
        print( "no input files" )
        return []
    
    if isinstance(files,str): files = [ files ]
    
    _out = []
    
    for file in files:
        if file.endswith(".py") or "=" in file: continue
        _out += file.split(",")
 
    out = []
        
    for f in _out :
        if f.startswith(("root://","http://")): out.append(f)
        else:  out += glob.glob(f)
 
    if not out :
        print( "no matching files", _out )
 
    if args: clean_args( _out, args, "--filesInput" )      
        
    return out
        
 
            

parse_signatures()

parse_signatures	(		signatures,
			args = None )

Definition at line 271 of file TrigIDR4MonConfig.py.

def parse_signatures( signatures, args=None ) :
    if not signatures: return None 
    sigs = []
    for sig in signatures:
        if sig.endswith(".py") or "=" in sig: continue
        sigs.append( sig )
 
    if args: clean_args( sigs, args, "--signatures" )    
 
    return sigs
 
 

TrigIDR4Mon_builder()

TrigIDR4Mon_builder	(		flags = None,
			name = "NoName" )

Definition at line 135 of file TrigIDR4MonConfig.py.

def TrigIDR4Mon_builder( flags=None, name="NoName" ):
        from AthenaConfiguration.ComponentFactory import CompFactory
        alg =  CompFactory.TrigIDR4Mon( name=name )
        return alg
 
 
 
# create a separate specific monTool for each analysis chain
# - simplifies the overall analysis configuration
 

TrigIDR4MonConfig()

TrigIDR4MonConfig	(		flags,
			monlevels = None )

Definition at line 28 of file TrigIDR4MonConfig.py.

def TrigIDR4MonConfig( flags, monlevels=None ):
        return TrigIDR4MonitoringCA( flags, monlevels )
 
 
 
# component accumulator wrapper around the overall
# monitoring functiom                
 

TrigIDR4Monitoring()

TrigIDR4Monitoring	(		flags,
			name = None,
			monlevel = None,
			kak = None )

Definition at line 71 of file TrigIDR4MonConfig.py.

def TrigIDR4Monitoring( flags, name=None, monlevel=None, kak=None ) :  
 
        tools = []
 
        from AthenaCommon.Logging import logging
        log = logging.getLogger("TrigIDR4Monitoring")
 
        log.info( f"Creating monitoring: {name}" )
 
        # had key for a reason in the past - I wonder why it is
        # not being used now ??
        #  key     = "All"
        toolkey = "All"
 
        if monlevel is not None:
                log.info( "TIDA monitoring not None: monlevel: " + monlevel )        
                if "t0" in monlevel:
                        #    key     = "Expert"
                        toolkey = "Expert"
                elif "shifter" in monlevel:
                        #    key     = "Shifter"
                        toolkey = "Shifter"
 
        for node in flags.nodes(): log.info( f"Configuring analysis : {node.name()}" )
 
        for node in flags.nodes():
                TrigIDR4MonSignature( node, node.name(), toolkey, tools, monlevel, kak )
 
        return tools
 
 
 

TrigIDR4MonitoringCA()

TrigIDR4MonitoringCA	(		iflags,
			monlevels = None )

Definition at line 36 of file TrigIDR4MonConfig.py.

def TrigIDR4MonitoringCA( iflags, monlevels=None ):
 
        flags = decodeFlags( iflags )
 
        from AthenaMonitoring import AthMonitorCfgHelper
        monConfig = AthMonitorCfgHelper( flags, "TrigIDR4Mon" )
        
        ca = ComponentAccumulator()
        
        #        print( "monlevel: ", monlevels )
 
        if flags.Input.isMC:
                # this turns on the centra athena decoration algorithm
                if flags.IDTPM2.useDecorations:
                        from TrigIDR4Monitoring.TruthSelectBase import TruthPerigeeDecoratorCfg
                        ca.merge( TruthPerigeeDecoratorCfg( flags ) )
 
        # maybe this is too soom to specialise to IDTPM2, but hey ...
        
        algs  = TrigIDR4Monitoring( flags.IDTPM2, "Tier0", monlevel="idMon:t0:shifter", kak=ca )
 
        #   if flags.Input.isMC:    
        #        algs += TrigIDR4Monitoring( flags.IDTPM2, name="PhysVal", monlevel="idMon:t0" , kak=ca )
        #        algs += TrigIDR4Monitoring( flags.IDTPM2, name="PhysValShifter", monlevel="idMon:shifter", kak=ca )
 
        for a in algs : monConfig.addAlgorithm(a)
 
        ca.merge(monConfig.result())
        return ca
 
 
# As these debug ssettings will make things very slow, we don't want these
# but it is useful to leave this here to facilitate easy debugging
# ComponentAccumulator.debugMode = "trackCA trackEventAlgo trackPublicTool trackPrivateTool"
 

TrigIDR4MonSignature()

TrigIDR4MonSignature	(		flags,
			key,
			toolkey,
			tools,
			monlevel,
			kak )

Definition at line 103 of file TrigIDR4MonConfig.py.

def TrigIDR4MonSignature( flags, key, toolkey, tools, monlevel, kak ) :
        
        tida = TrigIDR4Mon_builder( flags, name = f"ID{key}_{toolkey}Tool" )
        
        tida.SliceTag = flags.SliceTag
        
        from TrigInDetMonitoring.TIDAChains import getchains
 
        hltchains = False
 
        for pattern in flags.Chains :
                if chainString(pattern).head:
                        hltchains = True
                        break
                
        if hltchains : chains = getchains( flags, flags.Chains, monlevel )
        else:          chains = flags.Chains
 
        if  len(chains)==0 : raise RuntimeError(f"No matched chains for Signature: {flags.name()}")
        
        if  len(chains)>0 : 
 
                tida.MonTools = createTATools( flags, flags.SliceTag, chains )
 
                tools += [ tida ]
 
        # just because I don't like hanging indentations at ends of functions 
        return
 
                
 
# create the actual algorithm 

Variable Documentation

AODFixesDone

python.TrigIDR4MonConfig.AODFixesDone

Definition at line 348 of file TrigIDR4MonConfig.py.

cfg

python.TrigIDR4MonConfig.cfg = MainServicesCfg(tflags)

Definition at line 363 of file TrigIDR4MonConfig.py.

doExpressProcessing

python.TrigIDR4MonConfig.doExpressProcessing

Definition at line 336 of file TrigIDR4MonConfig.py.

file

str python.TrigIDR4MonConfig.file = 'AOD.pool.root'

Definition at line 325 of file TrigIDR4MonConfig.py.

Files

python.TrigIDR4MonConfig.Files

Definition at line 327 of file TrigIDR4MonConfig.py.

flags

python.TrigIDR4MonConfig.flags = initConfigFlags()

Definition at line 321 of file TrigIDR4MonConfig.py.

HISTFileName

python.TrigIDR4MonConfig.HISTFileName

Definition at line 333 of file TrigIDR4MonConfig.py.

isMC

python.TrigIDR4MonConfig.isMC

Definition at line 331 of file TrigIDR4MonConfig.py.

Nevents

int python.TrigIDR4MonConfig.Nevents = 25000

Definition at line 374 of file TrigIDR4MonConfig.py.

tflags

python.TrigIDR4MonConfig.tflags = decodeFlags( flags )

Definition at line 350 of file TrigIDR4MonConfig.py.

withDetails

python.TrigIDR4MonConfig.withDetails

Definition at line 372 of file TrigIDR4MonConfig.py.