prune_datastore.py

#!/usr/bin/env python3
 
 
 
import basf2
from ROOT import Belle2
from b2test_utils import clean_working_directory, safe_process
 
 
class TestModule(basf2.Module):
    """Test if the DataStore contains the expected content."""
 
    def __init__(self, is_inverted):
        """Create a new instance. If is_inverted is True we check of absence of content"""
        super().__init__()
        
        self._is_inverted_is_inverted = is_inverted
 
    def event(self):
        """reimplementation of Module::event().
 
        Checks for the amount of PXD Clusters and PXD Digits after
        the prune module was run
        """
 
        PXDClusters = Belle2.PyStoreArray('PXDClusters')
        PXDDigits = Belle2.PyStoreArray('PXDDigits')
 
        # PXDClusters are in our keep list, should still be there
        if self._is_inverted_is_inverted:
            assert PXDClusters.getEntries() == 0
            # while the PXDDigits should be empty
            assert PXDDigits.getEntries() > 0
        else:
            assert PXDClusters.getEntries() > 0
            # while the PXDDigits should be empty
            assert PXDDigits.getEntries() == 0
 
        # ensure the eventmetadata has been kept, which is implicitly done by
        # PruneDataStore
        evtmetadata = Belle2.PyStoreObj('EventMetaData')
        assert evtmetadata
 
 
basf2.set_log_level(basf2.LogLevel.ERROR)
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))
# find file to read
input_file = basf2.find_file('framework/tests/root_input.root')
 
with clean_working_directory():
    main = basf2.Path()
 
    main.add_module('RootInput', inputFileName=input_file)
    main.add_module('EventInfoPrinter')
    main.add_module('PrintCollections')
    main.add_module('PruneDataStore', matchEntries=['PXDClusters.*'])
    main.add_module('PrintCollections')
    main.add_module(TestModule(False))
 
    # ensure the pruned datastore is still write-able to disk
    main.add_module('RootOutput', outputFileName='prune_datastore_output_test.root', updateFileCatalog=False)
 
    # Process events
    basf2.process(main)
 
    # now test if the negated logic works, too
    main = basf2.Path()
 
    main.add_module('RootInput', inputFileName=input_file)
    main.add_module('EventInfoPrinter')
    main.add_module('PrintCollections')
    main.add_module('PruneDataStore', matchEntries=['PXDClusters.*'], keepMatchedEntries=False)
    main.add_module('PrintCollections')
    main.add_module(TestModule(True))
 
    # ensure the pruned datastore is still write-able to disk
    main.add_module('RootOutput', outputFileName='prune_datastore_output_test.root', updateFileCatalog=False)
 
    # Process events
    basf2.process(main)
 
    # now test if a regex which cannot be compiled is properly reported
    main = basf2.Path()
 
    main.add_module('RootInput', inputFileName=input_file)
    main.add_module('EventInfoPrinter')
    main.add_module('PrintCollections')
    main.add_module('PruneDataStore', matchEntries=['[a-b][a'], keepMatchedEntries=False)
    main.add_module('PrintCollections')
 
    # Process events
    assert(not safe_process(main) == 0)