Belle II Software development
processor.py
1#!/usr/bin/env python3
2
3
10import basf2
11import hbasf2
12from softwaretrigger import constants
13from softwaretrigger.processing import finalize_zmq_path, setup_basf2_and_db, start_zmq_path
14
15
16args = setup_basf2_and_db(event_distribution_mode=constants.EventDistributionModes.zmq)
17
18path, reco_path = start_zmq_path(args, location=constants.Location.expressreco,
19 event_distribution_mode=constants.EventDistributionModes.zmq)
20
21# Monitor/Debug modules
22reco_path.add_module('MonitorData')
23reco_path.add_module('ElapsedTime', EventInterval=10000)
24
25finalize_zmq_path(path, args, location=constants.Location.expressreco)
26
27basf2.print_path(path)
28hbasf2.process(path, [args.dqm, args.output], True)