eventlimiter.py

#!/usr/bin/env python3
 

 
import basf2
from ROOT import Belle2
 

num_events = {}
 
 
class CountEvents(basf2.Module):
 
    """
    Count the number of events passing this module and create a dictionary
    of {(exp,run): events}
    """
 
    def initialize(self):
        """Not implemented"""
 
    def initialize(self): …
    def beginRun(self):
        """Creates an entry in the global num_events dictionary"""
        global num_events
        evtmetadata = Belle2.PyStoreObj('EventMetaData')
        run = evtmetadata.obj().getRun()
        exp = evtmetadata.obj().getExperiment()
        if (exp, run) not in num_events:
            num_events[(exp, run)] = 0
 
    def beginRun(self): …
    def event(self):
        """Increments the right (Exp,Run) entry in the num_events dictionary"""
        global num_events
        evtmetadata = Belle2.PyStoreObj('EventMetaData')
        run = evtmetadata.obj().getRun()
        exp = evtmetadata.obj().getExperiment()
        num_events[(exp, run)] += 1
 
 
    def event(self): …
class CountEvents(basf2.Module): …
input_events = 1000
max_events = 500
 
main = basf2.Path()
main.add_module("EventInfoSetter", evtNumList=[input_events] * 3, expList=[0, 0, 1], runList=[0, 1, 0])
eventlimiter_mod = main.add_module('EventLimiter', maxEventsPerRun=500)
 
success_path = basf2.Path()
success_count = success_path.add_module(CountEvents())
eventlimiter_mod.if_true(success_path)
 
basf2.process(main)
 
print(basf2.statistics)
 
for passing_events in num_events.values():
    assert passing_events == max_events