16 def storeSteering(name, tag):
18 baseDir =
'/group/belle2/dataprod/dp_managers/ddossett/airflow/output_data'
20 def getRun(x):
return int(re.findall(
'[0-9]*$', x)[0])
23 if not isinstance(tag, list):
25 res = glob(baseDir+
'/'+tag+
'/mumu_2trk/e12/*')
30 res += glob(baseDir+
'/'+t+
'/mumu_2trk/e12/*')
32 res = sorted(res, key=getRun)
34 fOut = open(name,
'w')
36 fOut.write(
'{"hlt_mumu": [')
38 for i, r
in enumerate(res):
40 fOut.write(
'["' + r +
'", [12, '+str(n)+
']]')
49 def storeSteering2(name, tag):
50 baseDir =
'/group/belle2/dataprod/Data/OfficialReco/proc11/e00'+tag+
'/4S/r*/skim/hlt_mumu_2trk/mdst'
52 baseDir =
'/group/belle2/dataprod/Data/release-04-02-04/DB00001113/' +\
53 'bucket12/e0012/4S_offres/GoodRuns/r*/skim/hlt_mumu_2trk/mdst'
55 baseDir =
'/group/belle2/dataprod/Data/OfficialReco/proc11/e0008/4S_offres/r*/skim/hlt_mumu_2trk/mdst'
58 baseDir =
'/group/belle2/dataprod/Data/OfficialReco/proc11/e0008/4S_scan/r*/skim/hlt_mumu_2trk/mdst'
63 def getRun(r):
return int(re.findall(
'/r[0-9]*/', r)[0][2:-1])
65 res = sorted(res, key=getRun)
67 fOut = open(name,
'w')
69 fOut.write(
'{"hlt_mumu": [')
71 for i, r
in enumerate(res):
73 exp = 12
if tag ==
'bucket12' else int(tag)
74 fOut.write(
'["' + r +
'", ['+str(exp)+
', '+str(n)+
']]')
83 storeSteering2(
'steerings/input_data_exp8off.json',
'08off')
84 storeSteering2(
'steerings/input_data_exp8scan.json',
'08scan')
86 storeSteering2(
'steerings/input_data_exp7.json',
'07')
87 storeSteering2(
'steerings/input_data_exp8.json',
'08')
88 storeSteering2(
'steerings/input_data_exp10.json',
'10')
90 storeSteering(
'steerings/input_data_bucket9.json', 71)
91 storeSteering(
'steerings/input_data_bucket10.json', 91)
92 storeSteering(
'steerings/input_data_bucket11.json', [110, 112])
93 storeSteering2(
'steerings/input_data_bucket12.json',
'bucket12')
94 storeSteering(
'steerings/input_data_bucket13.json', 139)
95 storeSteering(
'steerings/input_data_bucket14.json', 166)
96 storeSteering(
'steerings/input_data_bucket15.json', 192)