python.RDOtoRDO_TRIG_Skeleton Namespace Reference

Functions
def	configureFlags (runArgs)
def	fromRunArgs (runArgs)

Variables
	log = logging.getLogger('RDOtoRDO_TRIG')
	jobPropertiesDisallowed

Function Documentation

configureFlags()

def python.RDOtoRDO_TRIG_Skeleton.configureFlags

(

runArgs

)

Definition at line 15 of file RDOtoRDO_TRIG_Skeleton.py.

def configureFlags(runArgs):
    # some basic settings here...
    from AthenaConfiguration.AllConfigFlags import initConfigFlags
    flags = initConfigFlags()
    from PyJobTransforms.CommonRunArgsToFlags import commonRunArgsToFlags
    commonRunArgsToFlags(runArgs, flags)
 
    # Set standard flags for HLT jobs
    runHLT.set_flags(flags)
 
    # Input
    if hasattr(runArgs, 'inputRDOFile'):
        flags.Input.Files = runArgs.inputRDOFile
 
    # Output 
    if hasattr(runArgs, 'outputRDO_TRIGFile'):
        flags.Output.RDOFileName = runArgs.outputRDO_TRIGFile
        log.info("---------- Configured RDO_TRIG output")
 
    from RecJobTransforms.RecoConfigFlags import recoRunArgsToFlags
    recoRunArgsToFlags(runArgs, flags)
 
    from AthenaConfiguration.Enums import ProductionStep
    flags.Common.ProductionStep=ProductionStep.Reconstruction
 
    # Setup perfmon flags from runargs
    from PerfMonComps.PerfMonConfigHelpers import setPerfmonFlagsFromRunArgs
    setPerfmonFlagsFromRunArgs(flags, runArgs)
 
    # process pre-include/exec
    processPreInclude(runArgs, flags)
    processPreExec(runArgs, flags)
 
    # To respect --athenaopts
    flags.fillFromArgs()
 
    # Lock flags
    flags.lock()
 
    return flags
 
 
 

fromRunArgs()

def python.RDOtoRDO_TRIG_Skeleton.fromRunArgs

(

runArgs

)

Definition at line 58 of file RDOtoRDO_TRIG_Skeleton.py.

def fromRunArgs(runArgs):
 
    import time
    timeStart = time.time()
 
    flags = configureFlags(runArgs)
 
    from AthenaConfiguration.MainServicesConfig import MainServicesCfg
    cfg = MainServicesCfg(flags)
    from AthenaPoolCnvSvc.PoolReadConfig import PoolReadCfg
    cfg.merge(PoolReadCfg(flags))
    cfg.merge( runHLT.runHLTCfg(flags) )
    # Enabling PerfMon always for trigger jobs regardless of PerfMon flags (unlike most other skeletons)
    cfg.merge( PerfMonMTSvcCfg(flags) )
 
    # Post-include
    processPostInclude(runArgs, flags, cfg)
 
    # Post-exec
    processPostExec(runArgs, flags, cfg)
 
    from AthenaCommon.Constants import INFO
    if flags.Exec.OutputLevel <= INFO:
        cfg.printConfig()
 
    # Run the final accumulator
    sc = cfg.run()
    timeFinal = time.time()
    log.info("Run RDOtoRDO_TRIG_skeleton in %d seconds", timeFinal - timeStart)
 
    import sys
    sys.exit(sc.isFailure())

Variable Documentation

jobPropertiesDisallowed

python.RDOtoRDO_TRIG_Skeleton.jobPropertiesDisallowed

Definition at line 12 of file RDOtoRDO_TRIG_Skeleton.py.

log

python.RDOtoRDO_TRIG_Skeleton.log = logging.getLogger('RDOtoRDO_TRIG')

Definition at line 8 of file RDOtoRDO_TRIG_Skeleton.py.