AthenaPoolTestStep2WriteDoubleSelector.py

Go to the documentation of this file.

 
 
 
import AthenaCommon.AtlasUnixStandardJob
 
 
from AthenaCommon.AlgSequence import AlgSequence
topSequence = AlgSequence()
 
 
from AthenaCommon.AppMgr import theApp
 
 
from AthenaCommon.AppMgr import ServiceMgr as svcMgr
 
# Set that we are running MC+MC overlay in MT mode
from OverlayCommonAlgs.OverlayFlags import overlayFlags
overlayFlags.isDataOverlay.set_Value_and_Lock(False)
overlayFlags.isOverlayMT.set_Value_and_Lock(True)
 
#--------------------------------------------------------------
# Load POOL support for DoubleEventSelector
#--------------------------------------------------------------
import AthenaPoolCnvSvc.ReadAthenaPoolDouble
import AthenaPoolCnvSvc.WriteAthenaPool
 
#--------------------------------------------------------------
# Define the input parameters
#--------------------------------------------------------------
 
# Add in DoubleEventSelector
svcMgr.EventSelector.InputCollections = [ "SimplePoolFile1.root" ]
svcMgr.SecondaryEventSelector.InputCollections = [ "SimplePoolFile2.root" ]
 
svcMgr.EventSelector.OutputLevel = DEBUG
svcMgr.SecondaryEventSelector.OutputLevel = DEBUG
 
#--------------------------------------------------------------
# Event related parameters
#--------------------------------------------------------------
theApp.EvtMax = 5
 
#--------------------------------------------------------------
# Application: AthenaPoolTest options
#--------------------------------------------------------------
from AthenaPoolTest.AthenaPoolTestConf import AthenaPoolTestDataWriter
topSequence += AthenaPoolTestDataWriter( "AthenaPoolTestDataWriter" )
AthenaPoolTestDataWriter.PartialCreate = True
AthenaPoolTestDataWriter.ReadOtherHalf = True
 
#--------------------------------------------------------------
# Output options
#--------------------------------------------------------------
# ItemList:
include( "EventAthenaPool/EventAthenaPoolItemList_joboptions.py" )
include( "AthenaPoolTestAthenaPool/AthenaPoolTestAthenaPoolItemList_joboptions.py" )
 
print(fullItemList)
 
from AthenaPoolCnvSvc.WriteAthenaPool import AthenaPoolOutputStream
Stream3 = AthenaPoolOutputStream( "Stream3", noTag=True )
 
# Run OutputStream as an algorithm
topSequence += Stream3
# Must make sure that no OutStream's have been declared
theApp.OutStream     = []; 
# Stream's output file
Stream3.WritingTool = "AthenaOutputStreamTool"
Stream3.OutputFile  = "SimplePoolFile3.root"
# List of DO's to write out
#Stream1.ItemList   += fullItemList
Stream3.ItemList   += ["EventInfo#*"]
# Write out only a new set of cols 1,2,3, and matrix
Stream3.ItemList   += ["IAthenaPoolTestCollection#AthenaPoolTestCollection_1"]
Stream3.ItemList   += ["IAthenaPoolTestCollection#AthenaPoolTestCollection_2"]
Stream3.ItemList   += ["IAthenaPoolTestCollection#AthenaPoolTestCollection_3"]
Stream3.ItemList   += ["AthenaPoolTestMatrix#*"]
 
print(Stream3.ItemList)
 
# Set file catalogs to avoid collisions.
from PoolSvc import PoolSvcConf
PoolSvc = PoolSvcConf.PoolSvc()
PoolSvc.ReadCatalog = ['file:AthenaPoolTestWriteDoubleSelector_catalog.xml']
PoolSvc.WriteCatalog = 'file:AthenaPoolTestStep2WriteDoubleSelector_catalog.xml'
 
 
#--------------------------------------------------------------
# Set output level threshold (2=DEBUG, 3=INFO, 4=WARNING, 5=ERROR, 6=FATAL )
#--------------------------------------------------------------
svcMgr.MessageSvc.OutputLevel = WARNING
svcMgr.MessageSvc.debugLimit  = 100000
AthenaPoolTestDataWriter.OutputLevel = DEBUG
 
from AthenaServices import AthenaServicesConf
AthenaEventLoopMgr = AthenaServicesConf.AthenaEventLoopMgr()
AthenaEventLoopMgr.OutputLevel = INFO
AthenaEventLoopMgr.UseSecondaryEventNumber = True
svcMgr += AthenaEventLoopMgr
 
# No stats printout
include( "AthenaPoolTest/NoStats_jobOptions.py" )
 
#==============================================================
#
# End of job options file
#