ViewScheduling.py

Go to the documentation of this file.

#
#  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
#
 
 
 
#--------------------------------------------------------------
# ATLAS default Application Configuration options
#--------------------------------------------------------------
 
# Configure the scheduler
from AthenaCommon.AlgScheduler import AlgScheduler
AlgScheduler.ShowControlFlow( True )
AlgScheduler.ShowDataDependencies( True )
AlgScheduler.EnableConditions( True )
AlgScheduler.OutputLevel( INFO )
AlgScheduler.setAlgRanking( "PCE" )
 
# Control flow
from AthenaCommon.AlgSequence import AthSequencer
allViewAlgorithms = AthSequencer( "allViewAlgorithms" )
allViewAlgorithms.ModeOR = False
allViewAlgorithms.Sequential = False
allViewAlgorithms.StopOverride = True
makeViewSequence = AthSequencer( "makeViewSequence" )
makeViewSequence.ModeOR = False
makeViewSequence.Sequential = True
makeViewSequence.StopOverride = False
 
# Event-level algorithm sequence
from AthenaCommon.AlgSequence import AlgSequence
job = AlgSequence()
 
# Make views
makeViewSequence += CfgMgr.AthViews__ViewSubgraphAlg("make_alg")
makeViewSequence.make_alg.ViewBaseName = "view"
makeViewSequence.make_alg.ViewNumber = 10
makeViewSequence.make_alg.ViewNodeName = "allViewAlgorithms"
makeViewSequence.make_alg.Scheduler = AlgScheduler.getScheduler()
 
# View algorithms
ViewTest = CfgMgr.AthViews__ViewTestAlg("view_test")
allViewAlgorithms += ViewTest
#
ViewVerify = CfgMgr.AthViews__ViewDataVerifier("view_verify")
ViewVerify.DataObjects = { ('int','view_start') }
allViewAlgorithms += ViewVerify
#
dflow_alg1 = CfgMgr.AthViews__DFlowAlg1("dflow_alg1")
allViewAlgorithms += dflow_alg1
#
dflow_alg2 = CfgMgr.AthViews__DFlowAlg2("dflow_alg2")
allViewAlgorithms += dflow_alg2
#
dflow_alg3 = CfgMgr.AthViews__DFlowAlg3("dflow_alg3")
allViewAlgorithms += dflow_alg3
 
# Add the view algorithms to the job
makeViewSequence += allViewAlgorithms
 
# Merge views
makeViewSequence += CfgMgr.AthViews__ViewMergeAlg("merge_alg")
 
job += makeViewSequence
 
# Conditions alg - creates an object that dflow_alg3 will retrieve
condSeq = AthSequencer("AthCondSeq")
condSeq += CfgMgr.AthViews__ConditionTestAlg( "condTestAlg" )
 
svcMgr.ConditionStore.OutputLevel = VERBOSE
 
#--------------------------------------------------------------
# Event related parameters
#--------------------------------------------------------------
theApp.EvtMax = 10
 
#==============================================================
#
# End of job options file
#