root_input.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
 
import os
import basf2
from ROOT import Belle2
from b2test_utils import safe_process, clean_working_directory
 
basf2.conditions.disable_globaltag_replay()
basf2.set_random_seed("something important")
# make sure FATAL messages don't have the function signature as this makes
# problems with clang printing namespaces differently
basf2.logging.set_info(basf2.LogLevel.FATAL, basf2.logging.get_info(basf2.LogLevel.ERROR))
basf2.logging.enable_summary(False)
 
 
class NoopModule(basf2.Module):
    """Doesn't do anything."""
 
 
with clean_working_directory():
    for filename in ["root_input.root", "chaintest_empty.root", "chaintest_1.root", "chaintest_2.root"]:
        os.symlink(basf2.find_file(f'framework/tests/{filename}'), filename)
 
    main = basf2.Path()
    # not used for anything, just checking wether the master module
    # can be found if it's not the first module in the path.
    main.add_module(NoopModule())
    # load all branches, minus PXDClusters (relations with PXDClusters are automatically excluded)
    # (yes, we also added PXDClusters in branchNames, to check if it's overridden by excludeBranchNames)
    input_module = main.add_module("RootInput", inputFileName="root_input.root",
                                   branchNames=['EventMetaData', 'PXDDigits', 'PXDTrueHits', 'PXDClusters'],
                                   excludeBranchNames=['PXDClusters'], skipNEvents=1, logLevel=basf2.LogLevel.WARNING)
    # print event information and datastore contents
    main.add_module("EventInfoPrinter")
    main.add_module("PrintCollections", printForEvent=0)
 
    # Process events
    assert safe_process(main) == 0
 
    # Test restricting the number of events per file
    # This issues a warning because a part of the events is out of range
    input_module.param('entrySequences', ["0,3:10,23"])
    assert safe_process(main) == 0
 
    # Test starting directly with a given event. There will be a fatal error if the
    # event is not found in the file so let's call process() in a child process to
    # not be aborted
    for evtNo in range(1, 6):
        main = basf2.Path()
        main.add_module("RootInput", inputFileName='root_input.root',
                        branchNames=["EventMetaData"], skipToEvent=[0, 1, evtNo], logLevel=basf2.LogLevel.WARNING)
        main.add_module("EventInfoPrinter")
        safe_process(main)
 
    # Test eventSequences in detail
    main = basf2.Path()
    input_module = main.add_module('RootInput', inputFileNames=['chaintest_1.root', 'chaintest_2.root'],
                                   logLevel=basf2.LogLevel.WARNING)
    # The first file contains the following event numbers (in this order)
    # 2, 6, 5, 9, 10, 11, 8, 12, 0, 13, 15, 16
    # We select more event than the file contains, to check if it works anyway
    # The second file contains the following event numbers (in this order)
    # 7, 6, 3, 8, 9, 12, 4, 11, 10, 16, 13, 17, 18, 14, 15
    input_module.param('entrySequences', ['0,3:4,10:100', '1:2,4,12:13'])
 
    expected_event_numbers = [2, 9, 10, 15, 16, 6, 3, 9, 18, 14]
    processed_event_numbers = []
 
    class TestingModule(basf2.Module):
        """
        Test module which writes out the processed event numbers
        into the global processed_event_numbers list
        """
 
        def event(self):
            """
            Called for each event
            """
            global processed_event_numbers
            emd = Belle2.PyStoreObj('EventMetaData')
            processed_event_numbers.append(emd.obj().getEvent())
 
        def terminate(self):
            """
            perform check
            """
            # We only want to do the check if we actually execute the process() but
            # since this script is called from basf2_args with --dry-run this is not
            # always the case
            assert expected_event_numbers == processed_event_numbers
 
    main.add_module(TestingModule())
    assert safe_process(main) == 0
 
    basf2.set_random_seed("something important")
    # make sure FATAL messages don't have the function signature as this makes
    # problems with clang printing namespaces differently
    basf2.logging.set_info(basf2.LogLevel.FATAL, basf2.logging.get_info(basf2.LogLevel.ERROR))
 
    # Test eventSequences parameter ':' in detail
    main = basf2.Path()
    input_module = main.add_module('RootInput', inputFileNames=['chaintest_1.root', 'chaintest_2.root'],
                                   logLevel=basf2.LogLevel.WARNING)
    # The first file contains the following event numbers (in this order)
    # 2, 6, 5, 9, 10, 11, 8, 12, 0, 13, 15, 16
    # We select the complete first file.
    # The second file contains the following event numbers (in this order)
    # 7, 6, 3, 8, 9, 12, 4, 11, 10, 16, 13, 17, 18, 14, 15
    input_module.param('entrySequences', [':', '1:2,4,12:13'])
 
    expected_event_numbers = [2, 6, 5, 9, 10, 11, 8, 12, 0, 13, 15, 16, 6, 3, 9, 18, 14]
    processed_event_numbers = []
 
    main.add_module(TestingModule())
 
    assert safe_process(main) == 0
 
    full_list = ["chaintest_empty.root", "chaintest_1.root", "chaintest_2.root", "chaintest_1.root"]
    for i in range(len(full_list)):
        main = basf2.Path()
        main.add_module('RootInput', inputFileNames=full_list[:i + 1])
        main.add_module("EventInfoPrinter")
        safe_process(main)