AthenaPool.py

Go to the documentation of this file.

# Copyright (C) 2002-2020 CERN for the benefit of the ATLAS collaboration
 

 
def _loadBasicAthenaPool():
    """Loads the basic services for AthenaPool"""
 
    from AthenaCommon import CfgMgr
    
    import AthenaCommon.AtlasUnixStandardJob  # noqa: F401
 
    from AthenaCommon.Logging import logging
    from AthenaCommon.AppMgr  import ServiceMgr as svcMgr
 
    msg = logging.getLogger( 'loadBasicAthenaPool' )
    msg.debug( "Loading basic services for AthenaPool..." )
 
    if not hasattr (svcMgr, 'PoolSvc'):
        svcMgr += CfgMgr.PoolSvc()
    svcMgr.PoolSvc.MaxFilesOpen = 0
    #if in AthAnalysisBase, we will set the outputlevel of PoolSvc to ERROR, to silence warnings about missing reflex types
    #detect AthAnalysisBase by looking at the CMTEXTRATAGS env var, if it contains 'ManaCore' then we are in AthAnalysisBase
    import os
    from AthenaCommon.Constants import ERROR
    if "ManaCore" in os.environ.get('CMTEXTRATAGS',""): svcMgr.PoolSvc.OutputLevel=ERROR
 
    svcMgr += CfgMgr.AthenaPoolCnvSvc()
 
    if not hasattr (svcMgr, 'EventPersistencySvc'):
        svcMgr += CfgMgr.EvtPersistencySvc( "EventPersistencySvc" )
    svcMgr.EventPersistencySvc.CnvServices += [ "AthenaPoolCnvSvc" ]
    if not hasattr (svcMgr, 'ProxyProviderSvc'):
        svcMgr += CfgMgr.ProxyProviderSvc()
 
    # Add in MetaDataSvc
    svcMgr += CfgMgr.MetaDataSvc( "MetaDataSvc" )
 
    # Make MetaDataSvc an AddressProvider
    svcMgr.ProxyProviderSvc.ProviderNames += [ "MetaDataSvc" ]
    if not hasattr (svcMgr, 'MetaDataStore'):
        svcMgr += CfgMgr.StoreGateSvc( "MetaDataStore" )
 
    msg.debug( "Loading basic services for AthenaPool... [DONE]" )
    return
 

_loadBasicAthenaPool()
 

del _loadBasicAthenaPool