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 Gaudi.Configuration import *
from Configurables import HiveWhiteBoard, HiveSlimEventLoopMgr, AvalancheSchedulerSvc, CPUCruncher, CPUCrunchSvc

# 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 = .01

ApplicationMgr(
    EvtMax=evtMax,
    EvtSel='NONE',
    ExtSvc=[whiteboard],
    EventLoop=slimeventloopmgr,
    TopAlg=[a1, a2, a3],
    MessageSvcType="InertMessageSvc",
    OutputLevel=DEBUG)