CTPMonitoringConfig.py

Go to the documentation of this file.

#
#  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
#
 
def CTPMonitoringConfig(flags):
    # local printing
    import logging
    local_logger = logging.getLogger('AthenaMonitoringCfg')
    info = local_logger.info
    info('In CTPMonitoringConfig')
 
    '''Function to call CTP DQ monitoring algorithms'''
    from AthenaConfiguration.ComponentAccumulator import ComponentAccumulator
    result = ComponentAccumulator()
    #get these for Data only
    if not flags.Input.isMC:
        info('CTPMonitoringConfig: attempting to add DATA COOL folders')
        if not flags.Common.isOnline:
          from IOVDbSvc.IOVDbSvcConfig import addFolders
          result.merge(addFolders(flags,'/LHC/DCS/FILLSTATE','DCS_OFL',className='CondAttrListCollection'))
          
        result.merge(addFolders(flags,'/TDAQ/RunCtrl/DataTakingMode','TDAQ',className='AthenaAttributeList'))
        info('CTPMonitoringConfig: added DATA COOL folders')
 
    # add CTP and MUCTPI data to ByteStreamAddressProviderSvc
    if flags.DQ.Environment in ('online', 'tier0', 'tier0Raw'):
        #info('In CTPMonitoringConfig DQ.Environment: %s', flags.DQ.Environment )
        from TriggerJobOpts.TriggerByteStreamConfig import ByteStreamReadCfg
        result.merge(ByteStreamReadCfg(flags, [
            "MuCTPI_RDO/MUCTPI_RDO",
            "CTP_RDO/CTP_RDO",
            #"MuCTPI_RIO/MUCTPI_RIO",
            "CTP_RIO/CTP_RIO"
        ]))
        info('In CTPMonitoringConfig added ByteStreamReadCfg MUCTPI_RDO,CTP_RDO,CTP_RIO' )
 
    # If we're not putting trigger objects in event store, can't monitor them
    if not flags.Trigger.Online.isPartition:
        if not flags.DQ.triggerDataAvailable:
            return result
 
    #isData = not flags.Input.isMC
    # monitoring algorithm configs
    # only when input is RAW
    #if flags.DQ.Environment in ('online', 'tier0', 'tier0Raw'):
 
    
 
    #info('before results_merge CTPMonitoringConfig')
    
    if flags.DQ.Environment not in ( 'AOD', 'DAOD_PHYS', 'tier0ESD'): #, 'tier0Raw' ): 
        from TrigT1CTMonitoring.BSMonitoringAlgorithm import BSMonitoringConfig
        result.merge(BSMonitoringConfig(flags))
        info('CTPMonitoringConfig: requested: result.merge(BSMonitoringConfig(flags))')
    info('after results_merge CTPMonitoringConfig')
    return result
 
if __name__=='__main__':
    from AthenaConfiguration.AllConfigFlags import initConfigFlags
    from AthenaConfiguration.MainServicesConfig import MainServicesCfg
 
    flags = initConfigFlags()
    from AthenaConfiguration.TestDefaults import defaultGeometryTags
    flags.GeoModel.AtlasVersion=defaultGeometryTags.RUN3
    flags.Scheduler.CheckDependencies = True
    flags.Scheduler.ShowDataDeps = True
    flags.Scheduler.ShowDataFlow = True
    flags.Scheduler.ShowControlFlow = True
    flags.Scheduler.EnableVerboseViews = True
    flags.Detector.GeometryZDC=False
    flags.Detector.GeometryAFP=False
    flags.Detector.GeometryALFA=False
    flags.Detector.GeometryLucid=False
    flags.Detector.GeometryMDT=False
    flags.Detector.GeometryMM=False
    flags.Detector.GeometryMuon=False
    flags.Trigger.decodeHLT=False
    flags.Trigger.enableL1MuonPhase1=False
    flags.Trigger.L1.doMuon=True
    flags.Trigger.L1.doCalo=False
    flags.Trigger.L1.doTopo=True
    flags.Trigger.L1.doCTP=True
    flags.Reco.EnableCombinedMuon=True   
    #flags.Reco.EnableTrigger = False
    # This does not work in this context
    # run = flags.GeoModel.Run
    # The EDM Version should be auto configured, but is not working at the moment, so is set by hand
 
    flags.Output.AODFileName="AOD.pool.root"
    flags.Output.HISTFileName="HIST.root"
    flags.Output.doWriteAOD=True
 
    flags.fillFromArgs()
    flags.lock()
    # Next line is for debugging
#    flags.dump()
 
    acc=MainServicesCfg(flags)
    acc.merge( CTPMonitoringConfig(flags) )
 
    status = acc.run()
    if status.isFailure():
        import sys
        sys.exit(-1)