run_postTracking_calibration.py

#!/usr/bin/env python3
 
 
 
# ---------------------------------------------------------------------------------------
# CAF calibration script: post-tracking calibration
# (BS13d carrier shifts, module T0 and common T0)
#
# data type: cdst (bhabha or dimuon)
#
# usage: basf2 run_postTracking_calibration.py expNo runFirst runLast [sample method]
#        sample = bhabha/dimuon (D = bhabha)
#        method = BF/LL (D = BF)
# ---------------------------------------------------------------------------------------
 
import sys
import glob
from caf import backends
from caf.framework import CAF
from basf2 import B2ERROR
from top_calibration import BS13d_calibration_cdst
from top_calibration import moduleT0_calibration_DeltaT, moduleT0_calibration_LL
from top_calibration import commonT0_calibration_BF, commonT0_calibration_LL
from top_calibration import offset_calibration
 
# ----- those parameters need to be adjusted before running -----------------------------
#
globalTags = ['Reco_master_patch', 'data_reprocessing_proc10']  # highest priority first
localDBs = []  # highest priority first, local DB's have higher priority than global tags
data_dir = '/group/belle2/dataprod/Data/OfficialReco/proc10/'
bhabha_skim_dir = 'skim/hlt_bhabha/cdst/sub00'
dimuon_skim_dir = 'offskim/offskim_mumutop/cdst/sub00'
main_output_dir = 'top_calibration'
default_sample = 'bhabha'
default_method = 'BF'  # default method for common T0
time_offset = 0  # [ns], set to -66.8 for proc9 or older (processed w/ release-3)
new_cdst_format = False  # set to True for input in new cdst format
#
# ---------------------------------------------------------------------------------------
 
# Argument parsing
argvs = sys.argv
if len(argvs) < 4:
    print("usage: basf2", argvs[0], "experiment runFirst runLast [sample method]")
    print("       sample = bhabha/dimuon (D = bhabha)")
    print("       method = BF/LL (D = BF)")
    sys.exit()
experiment = int(argvs[1])
run_first = int(argvs[2])
run_last = int(argvs[3])
sample = default_sample
method = default_method
 
if len(argvs) == 5:
    sample = argvs[4]
elif len(argvs) > 5:
    sample = argvs[4]
    method = argvs[5]
 
if sample == 'bhabha':
    skim_dir = bhabha_skim_dir
elif sample == 'dimuon':
    skim_dir = dimuon_skim_dir
else:
    B2ERROR("Invalid sample name: " + sample)
    sys.exit()
 
# Make list of files
inputFiles = []
expNo = 'e' + f'{experiment:04d}'
for run in range(run_first, run_last + 1):
    runNo = 'r' + f'{run:05d}'
    filename = f"{data_dir}/{expNo}/*/{runNo}/{skim_dir}/cdst*.root"
    inputFiles += glob.glob(filename)
 
if len(inputFiles) == 0:
    B2ERROR('No cdst files found in ' + data_dir + ' for exp=' + str(experiment) +
            ' runFirst=' + str(run_first) + ' runLast=' + str(run_last) +
            ' (skim_dir=' + skim_dir + ')')
    sys.exit()
 
# Output folder name
run_range = 'r' + f'{run_first:05d}' + '-' + f'{run_last:05d}'
output_dir = f"{main_output_dir}/postTracking-{sample}-{method}-{expNo}-{run_range}"
 
# Define calibrations
cal1 = BS13d_calibration_cdst(inputFiles, time_offset, globalTags, localDBs, new_cdst_format)
cal2 = moduleT0_calibration_DeltaT(inputFiles, globalTags, localDBs, new_cdst_format)
cal3 = moduleT0_calibration_LL(inputFiles, sample, globalTags, localDBs, new_cdst_format)
if method == 'BF':
    cal4 = commonT0_calibration_BF(inputFiles, globalTags, localDBs, new_cdst_format)
elif method == 'LL':
    cal4 = commonT0_calibration_LL(inputFiles, sample, globalTags, localDBs, new_cdst_format)
else:
    B2ERROR('Invalid method name: ' + method)
    sys.exit()
cal5 = offset_calibration(inputFiles, globalTags, localDBs, new_cdst_format)
 
cal1.backend_args = {"queue": "s"}
cal2.backend_args = {"queue": "s"}
cal3.backend_args = {"queue": "s"}
cal4.backend_args = {"queue": "s"}
cal5.backend_args = {"queue": "s"}
 
# Dependencies
cal2.depends_on(cal1)
cal3.depends_on(cal2)
cal4.depends_on(cal3)
cal5.depends_on(cal4)
 
# Add calibrations to CAF
cal_fw = CAF()
cal_fw.add_calibration(cal1)
cal_fw.add_calibration(cal2)
cal_fw.add_calibration(cal3)
cal_fw.add_calibration(cal4)
cal_fw.add_calibration(cal5)
cal_fw.output_dir = output_dir
cal_fw.backend = backends.LSF()
 
# Run calibration
cal_fw.run()