caf_ecl_time_shifts.py

 
 
"""Plot the crate time jumps"""
 
from prompt import CalibrationSettings
from reconstruction import prepare_cdst_analysis
 
 
 
 
 
settings = CalibrationSettings(name="ECL crystal time calibrations",
                               expert_username="ehill",
                               description=__doc__,
                               input_data_formats=["cdst", "mdst"],
                               input_data_names=["bhabha_all_calib"],
                               input_data_filters={"bhabha_all_calib": ["bhabha_all_calib"]},
                               depends_on=[])
 
 
 
 
 
 
 
def get_calibrations(input_data, **kwargs):
    """
    Parameters:
      input_data (dict): Should contain every name from the 'input_data_names' variable as a key.
        Each value is a dictionary with {"/path/to/file_e1_r5.root": IoV(1,5,1,5), ...}. Useful for
        assigning to calibration.files_to_iov
 
      **kwargs: Configuration options to be sent in. Since this may change we use kwargs as a way to help prevent
        backwards compatibility problems. But you could use the correct arguments in b2caf-prompt-run for this
        release explicitly if you want to.
 
        Currently only kwargs["output_iov"] is used. This is the output IoV range that your payloads should
        correspond to. Generally your highest ExpRun payload should be open ended e.g. IoV(3,4,-1,-1)
 
    Returns:
      list(caf.framework.Calibration): All of the calibration objects we want to assign to the CAF process
    """
    # Set up config options
 
    # In this script we want to use one sources of input data.
    # Get the input files  from the input_data variable
    # The input data should be the bhabha skim
    file_to_iov_physics = input_data["bhabha_all_calib"]
 
    # Could remove this limit on the number of files per run but will just
    # set to a large number in case we want to introduce it later.
    # Also, keeping it allows the crystal calibrations code to look like the
    # crates calibration code.
    max_events_per_run = 1
 
    # We filter addition files if there are more than [max_events_per_run] events per run.
    # I'm not sure but I hope this will speed up the collector stage.
    # The input data files are sorted alphabetically by b2caf-prompt-run
    # already. This procedure respects that ordering.
    from prompt.utils import filter_by_max_events_per_run
 
    reduced_file_to_iov_physics = filter_by_max_events_per_run(file_to_iov_physics, max_events_per_run)
    input_files_physics = list(reduced_file_to_iov_physics.keys())
 
    
    from basf2 import register_module, create_path
    from ROOT import Belle2
    from caf.framework import Collection
 
    
 
    # Set up the collector but with only one event per file
    root_input = register_module('RootInput', entrySequences=[f'0:{1}'])
 
    rec_path_bhabha = create_path()
    rec_path_bhabha.add_module(root_input)
    if 'Gearbox' not in rec_path_bhabha:
        rec_path_bhabha.add_module('Gearbox')
    if 'Geometry' not in rec_path_bhabha:
        rec_path_bhabha.add_module('Geometry', useDB=True)
 
    prepare_cdst_analysis(rec_path_bhabha)  # for new 2020 cdst format
 
    col_bhabha = register_module('eclTimeShiftsPlottingCollector')
    eclTCol = Collection(collector=col_bhabha,
                         # input_files=input_files_first_last,
                         input_files=input_files_physics,
                         pre_collector_path=rec_path_bhabha,
                         )
 
    
 
    from caf.framework import Calibration
 
    tShifts_alg = Belle2.ECL.eclTimeShiftsAlgorithm()
    tShifts_alg.debugFilenameBase = "eclTimeShiftsAlgorithm"
 
    # Define offsets so that the crysta+crate time plots are centred close to zero.
    # tShifts_alg.timeShiftForPlotStyle = arr.array('d', [0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,  \
    #                                       0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,  \
    #                                       0,0,0,0,0,0,0,0,0,0,0,0,0])
    # tShifts_alg.timeShiftForPlotStyle = arr.array('d', [-29, -40, -9., -13, -35, -39,   \
    #                                      -42, -24, -20, -22, -16, -23, -35, -31, -10,   \
    #                                      -23, -47, -23, -21, -7., -31, -22, -30, -30,   \
    #                                      -33, 5., 9., 12., -11, -19, -30, -29, -37, -19,   \
    #                                      -20, -23, 37., 37., 57., 27., 53., 26., 69., 27.,   \
    #                                      66., 73., 52., 42., 55., 71., 110, 52.])
 
    # +-17ns range allows for four 8ns crate time jumps in one direction
    # +-10ns range allows for two 8ns crate time jumps in one direction
 
    tShifts_alg.crysCrateShift_min = -30   # in ns
    tShifts_alg.crysCrateShift_max = 30    # in ns
 
    # Make the algorithm loop over the runs, not just the collector
    # tShifts_alg.algorithmReadPayloads = True
 
    
 
    cal_ecl_timeShifts = Calibration(name="ecl_t_shifts", algorithms=[tShifts_alg],
                                     input_files=input_files_physics)
    cal_ecl_timeShifts.add_collection(name="bhabha", collection=eclTCol)
    cal_ecl_timeShifts.save_payloads = False
 
    
    return [cal_ecl_timeShifts]