@@ -38,8 +38,10 @@ add_QC_JSON() {
3838 OUTPUT_SUFFIX+=" -$1 "
3939}
4040
41+ JSON_TEMP_FILES=" ()"
42+
4143QC_CONFIG=
42- QC_CONFIG_OVERRIDE=
44+ : ${ QC_CONFIG_OVERRIDE:= } # set to empty string only if not already set externally
4345: ${QC_DETECTOR_CONFIG_OVERRIDE:= } # set to empty string only if not already set externally
4446if [[ -z ${QC_JSON_FROM_OUTSIDE:- } && ! -z ${GEN_TOPO_QC_JSON_FILE:- } && -f $GEN_TOPO_QC_JSON_FILE ]]; then
4547 QC_JSON_FROM_OUTSIDE=$GEN_TOPO_QC_JSON_FILE
@@ -245,7 +247,71 @@ elif [[ -z ${QC_JSON_FROM_OUTSIDE:-} ]]; then
245247 DET_JSON_FILE=" QC_JSON_GLO_$i "
246248 if has_matching_qc $i && [ ! -z " ${! DET_JSON_FILE:- } " ]; then
247249 if [[ $i == " PRIMVTX" ]] && ! has_detector_reco ITS; then continue ; fi
248- if [[ $i == " ITSTPC" ]] && ! has_detectors_reco ITS TPC; then continue ; fi
250+ if [[ $i == " ITSTPC" ]] ; then
251+ if ! has_detectors_reco ITS TPC; then continue
252+ else
253+ # replace the input sources depending on the detector compostition and matching detectors
254+ ITSTPCMatchQuery=" trackITSTPC:GLO/TPCITS/0;trackITSTPCABREFS:GLO/TPCITSAB_REFS/0;trackITSTPCABCLID:GLO/TPCITSAB_CLID/0;trackTPC:TPC/TRACKS;trackTPCClRefs:TPC/CLUSREFS/0;trackITS:ITS/TRACKS/0;trackITSROF:ITS/ITSTrackROF/0;trackITSClIdx:ITS/TRACKCLSID/0;alpparITS:ITS/ALPIDEPARAM/0?lifetime=condition&ccdb-path=ITS/Config/AlpideParam;SVParam:GLO/SVPARAM/0?lifetime=condition&ccdb-path=GLO/Config/SVertexerParam"
255+ TRACKSOURCESK0=" ITS,TPC,ITS-TPC"
256+ if has_processing_step MATCH_SECVTX || has_detector_matching SECVTX ; then
257+ if [[ $SYNCMODE == 1 ]] || [[ $EPNSYNCMODE == 1 ]] ; then
258+ HAS_K0_ENABLED=$( jq -r .qc.tasks.MTCITSTPC.taskParameters.doK0QC " ${! DET_JSON_FILE} " )
259+ else
260+ HAS_K0_ENABLED=$( jq -r .qc.tasks.GLOMatchTrITSTPC.taskParameters.doK0QC " ${! DET_JSON_FILE} " )
261+ fi
262+ if [[ $HAS_K0_ENABLED == " true" ]]; then
263+ ITSTPCMatchQuery+=" ;p2decay3body:GLO/PVTX_3BODYREFS/0;decay3body:GLO/DECAYS3BODY/0;decay3bodyIdx:GLO/DECAYS3BODY_IDX/0;p2cascs:GLO/PVTX_CASCREFS/0;cascs:GLO/CASCS/0;cascsIdx:GLO/CASCS_IDX/0;p2v0s:GLO/PVTX_V0REFS/0;v0s:GLO/V0S/0;v0sIdx:GLO/V0S_IDX/0;pvtx_tref:GLO/PVTX_TRMTCREFS/0;pvtx_trmtc:GLO/PVTX_TRMTC/0;pvtx:GLO/PVTX/0;clusTPCoccmap:TPC/TPCOCCUPANCYMAP/0;clusTPC:TPC/CLUSTERNATIVE;clusTPCshmap:TPC/CLSHAREDMAP/0;trigTPC:TPC/TRIGGERWORDS/0"
264+ if has_secvtx_source ITS-TPC-TRD ; then
265+ ITSTPCMatchQuery+=" ;trigITSTPCTRD:TRD/TRGREC_ITSTPC/0;trackITSTPCTRD:TRD/MATCH_ITSTPC/0"
266+ TRACKSOURCESK0+=" ,ITS-TPC-TRD"
267+ fi
268+ if has_secvtx_source ITS-TPC-TOF ; then
269+ ITSTPCMatchQuery+=" ;matchITSTPCTOF:TOF/MTC_ITSTPC/0"
270+ TRACKSOURCESK0+=" ,ITS-TPC-TOF"
271+ fi
272+ if has_secvtx_source ITS-TPC-TRD-TOF ; then
273+ ITSTPCMatchQuery+=" ;matchITSTPCTRDTOF:TOF/MTC_ITSTPCTRD/0"
274+ TRACKSOURCESK0+=" ,ITS-TPC-TRD-TOF"
275+ fi
276+ if has_secvtx_source TPC-TRD ; then
277+ ITSTPCMatchQuery+=" ;trigTPCTRD:TRD/TRGREC_TPC/0;trackTPCTRD:TRD/MATCH_TPC/0"
278+ TRACKSOURCESK0+=" ,TPC-TRD"
279+ fi
280+ if has_secvtx_source TPC-TOF ; then
281+ ITSTPCMatchQuery+=" ;matchTPCTOF:TOF/MTC_TPC/0;trackTPCTOF:TOF/TOFTRACKS_TPC/0"
282+ TRACKSOURCESK0+=" ,TPC-TOF"
283+ fi
284+ if has_secvtx_source TPC-TRD-TOF ; then
285+ ITSTPCMatchQuery+=" ;matchTPCTRDTOF/TOF/MTC_TPCTRD/0"
286+ TRACKSOURCESK0+=" ,TPC-TRD-TOF"
287+ fi
288+ if has_secvtx_source TOF ; then
289+ ITSTPCMatchQuery+=" ;tofcluster:TOF/CLUSTERS/0"
290+ TRACKSOURCESK0+=" ,TOF"
291+ fi
292+ if has_secvtx_source TRD ; then
293+ TRACKSOURCESK0+=" ,TRD"
294+ fi
295+ fi
296+ TEMP_FILE=$( mktemp " ${i} " _XXXXXXX)
297+ if [[ $SYNCMODE == 1 ]] || [[ $EPNSYNCMODE == 1 ]] ; then
298+ cat " ${! DET_JSON_FILE} " | jq " (.dataSamplingPolicies[] | select(.id == \" ITSTPCmSampK0\" ) | .query) = \" $ITSTPCMatchQuery \" | .qc.tasks.MTCITSTPC.taskParameters.trackSourcesK0 = \" $TRACKSOURCESK0 \" " > " $TEMP_FILE "
299+ else
300+ cat " ${! DET_JSON_FILE} " | jq " .qc.tasks.GLOMatchTrITSTPC.dataSource.query = \" $ITSTPCMatchQuery \" | .qc.tasks.GLOMatchTrITSTPC.taskParameters.trackSourcesK0 = \" $TRACKSOURCESK0 \" " > " $TEMP_FILE "
301+ fi
302+ else
303+ # we need to force that the K0s part is disabled
304+ TEMP_FILE=$( mktemp " ${i} " _XXXXXXX)
305+ if [[ $SYNCMODE == 1 ]] || [[ $EPNSYNCMODE == 1 ]] ; then
306+ cat " ${! DET_JSON_FILE} " | jq " (.dataSamplingPolicies[] | select(.id == \" ITSTPCmSampK0\" ) | .query) = \" $ITSTPCMatchQuery \" | .qc.tasks.MTCITSTPC.taskParameters.trackSourcesK0 = \" $TRACKSOURCESK0 \" | .qc.tasks.MTCITSTPC.taskParameters.doK0QC = \" false\" " > " $TEMP_FILE "
307+ else
308+ cat " ${! DET_JSON_FILE} " | jq " .qc.tasks.GLOMatchTrITSTPC.dataSource.query = \" $ITSTPCMatchQuery \" | .qc.tasks.GLOMatchTrITSTPC.taskParameters.trackSourcesK0 = \" $TRACKSOURCESK0 \" | .qc.tasks.GLOMatchTrITSTPC.taskParameters.doK0QC = \" false\" " > " $TEMP_FILE "
309+ fi
310+ fi
311+ DET_JSON_FILE=TEMP_FILE
312+ JSON_TEMP_FILES+=(" $TEMP_FILE " )
313+ fi
314+ fi
249315 add_QC_JSON GLO_$i ${! DET_JSON_FILE}
250316 fi
251317 done
@@ -297,6 +363,11 @@ elif [[ -z ${QC_JSON_FROM_OUTSIDE:-} ]]; then
297363 fi
298364 MERGED_JSON_FILENAME=$( realpath $MERGED_JSON_FILENAME )
299365
366+ # Clean up: delete the temporary files after use
367+ for tf in " ${JSON_TEMP_FILES[@]} " ; do
368+ rm -f " $tf "
369+ done
370+
300371 if [[ " ${QC_REDIRECT_MERGER_TO_LOCALHOST:- } " == " 1" ]]; then
301372 sed -i.bak -E ' s/( *)"remoteMachine" *: *".*"(,?) *$/\1"remoteMachine": "127.0.0.1"\2/' $MERGED_JSON_FILENAME
302373 unlink $MERGED_JSON_FILENAME .bak
@@ -335,7 +406,9 @@ if [[ ! -z "${QC_JSON_FROM_OUTSIDE:-}" ]]; then
335406 QC_CONFIG_PARAM=" --local-batch=QC.root"
336407 fi
337408 fi
409+
338410 add_W o2-qc " --config json://$QC_JSON_FROM_OUTSIDE ${QC_CONFIG_PARAM} ${QC_CONFIG} "
411+
339412fi
340413
341414if [[ ! -z ${GEN_TOPO_QC_JSON_FILE:- } ]]; then
0 commit comments