passthrough.py

#!/usr/bin/env python3
 

import basf2
import hbasf2
from softwaretrigger import constants
from softwaretrigger.processing import setup_basf2_and_db, start_zmq_path, finalize_zmq_path, add_hlt_passthrough
 
 
args = setup_basf2_and_db(event_distribution_mode=constants.EventDistributionModes.zmq)
 
path, reco_path = start_zmq_path(args, location=constants.Location.hlt,
                                 event_distribution_mode=constants.EventDistributionModes.zmq)
add_hlt_passthrough(reco_path)
finalize_zmq_path(path, args, location=constants.Location.hlt)
 
basf2.print_path(path)
import ROOT  # noqa
ROOT.Belle2.Environment.Instance().setStats(True)
hbasf2.process(path, [args.dqm, args.output], True)