AutoLoadUnmetDataInputs.py

Go to the documentation of this file.

#!/usr/bin/env gaudirun.py
 
"""
Find and attribute unmet data inputs as outputs to a Data Loader algorithm.
"""
 
from Configurables import (
    AvalancheSchedulerSvc,
    CPUCruncher,
    CPUCrunchSvc,
    HiveSlimEventLoopMgr,
    HiveWhiteBoard,
)
from Gaudi.Configuration import *
 
# metaconfig
evtslots = 1
evtMax = 3
algosInFlight = 1
 
whiteboard = HiveWhiteBoard("EventDataSvc", EventSlots=evtslots, OutputLevel=INFO)
 
slimeventloopmgr = HiveSlimEventLoopMgr(SchedulerName="AvalancheSchedulerSvc")
 
AvalancheSchedulerSvc(
    ThreadPoolSize=algosInFlight, CheckDependencies=True, DataLoaderAlg="AlgA"
)
 
CPUCrunchSvc(shortCalib=True)
 
# Assemble the data flow graph
a1 = CPUCruncher("AlgA", Loader=True, OutputLevel=VERBOSE)
 
a2 = CPUCruncher("AlgB", OutputLevel=VERBOSE)
a2.inpKeys = ["/Event/A1"]
 
a3 = CPUCruncher("AlgC", OutputLevel=VERBOSE)
a3.inpKeys = ["/Event/A2"]
 
for a in [a1, a2, a3]:
    a.avgRuntime = 0.01
 
ApplicationMgr(
    EvtMax=evtMax,
    EvtSel="NONE",
    ExtSvc=[whiteboard],
    EventLoop=slimeventloopmgr,
    TopAlg=[a1, a2, a3],
    MessageSvcType="InertMessageSvc",
    OutputLevel=DEBUG,
)