Skip to content

Allow to run central barrel only #2219

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
sawenzel merged 1 commit into from
Dec 17, 2025
Merged

Allow to run central barrel only #2219

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
28 changes: 16 additions & 12 deletions MC/bin/o2dpg_qc_finalization_workflow.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -85,15 +85,16 @@ def add_QC_postprocessing(taskName, qcConfigPath, needs, runSpecific, prodSpecif

## The list of remote-batch workflows (reading the merged QC tasks results, applying Checks, uploading them to QCDB)
MFTDigitsQCneeds = []
for flp in range(5):
MFTDigitsQCneeds.extend(['mftDigitsQC'+str(flp)+'_local'+str(tf) for tf in range(1, ntimeframes + 1)])
add_QC_finalization('mftDigitsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/mft-digits-0.json', MFTDigitsQCneeds)
add_QC_finalization('mftClustersQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/mft-clusters.json')
add_QC_finalization('mftTracksQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/mft-tracks.json')
add_QC_finalization('mftMCTracksQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/mft-tracks-mc.json')
add_QC_finalization('emcRecoQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/emc-reco-tasks.json')
add_QC_finalization('emcBCQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/emc-reco-tasks.json')
#add_QC_finalization('tpcTrackingQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/tpc-qc-tracking-direct.json')
if isActive('MFT'):
for flp in range(5):
MFTDigitsQCneeds.extend(['mftDigitsQC'+str(flp)+'_local'+str(tf) for tf in range(1, ntimeframes + 1)])
add_QC_finalization('mftDigitsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/mft-digits-0.json', MFTDigitsQCneeds)
add_QC_finalization('mftClustersQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/mft-clusters.json')
add_QC_finalization('mftTracksQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/mft-tracks.json')
add_QC_finalization('mftMCTracksQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/mft-tracks-mc.json')
if isActive('EMC'):
add_QC_finalization('emcRecoQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/emc-reco-tasks.json')
add_QC_finalization('emcBCQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/emc-reco-tasks.json')
add_QC_finalization('tpcStandardQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/tpc-qc-standard-direct.json')
if isActive('TRD'):
add_QC_finalization('trdDigitsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/trd-standalone-task.json')
Expand Down Expand Up @@ -127,16 +128,19 @@ def add_QC_postprocessing(taskName, qcConfigPath, needs, runSpecific, prodSpecif
else:
add_QC_finalization('tofPIDQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/pidtofNoTRD.json')
add_QC_finalization('RecPointsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/ft0-reconstruction-config.json')
add_QC_finalization('FV0DigitsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/fv0-digits.json')
add_QC_finalization('FDDRecPointsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/fdd-recpoints.json')
if isActive('FV0'):
add_QC_finalization('FV0DigitsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/fv0-digits.json')
if isActive('FDD'):
add_QC_finalization('FDDRecPointsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/fdd-recpoints.json')
if isActive('CPV'):
add_QC_finalization('CPVDigitsQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/cpv-digits-task.json')
add_QC_finalization('CPVClustersQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/cpv-clusters-task.json')
if isActive('PHS'):
add_QC_finalization('PHSCellsClustersQC', 'json://${O2DPG_ROOT}/MC/config/QC/json/phs-cells-clusters-task.json')

# The list of QC Post-processing workflows
add_QC_postprocessing('tofTrendingHits', 'json://${O2DPG_ROOT}/MC/config/QC/json/tof-trending-hits.json', [QC_finalize_name('tofDigitsQC')], runSpecific=False, prodSpecific=True)
if isActive('TOF'):
add_QC_postprocessing('tofTrendingHits', 'json://${O2DPG_ROOT}/MC/config/QC/json/tof-trending-hits.json', [QC_finalize_name('tofDigitsQC')], runSpecific=False, prodSpecific=True)

return stages

Expand Down
61 changes: 34 additions & 27 deletions MC/bin/o2dpg_sim_workflow.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1382,13 +1382,13 @@ def getDigiTaskName(det):
workflow['stages'].append(FT0RECOtask)

#<--------- ITS-TPC track matching task
ITSTPCMATCHtask=createTask(name='itstpcMatch_'+str(tf), needs=[TPCRECOtask['name'], ITSRECOtask['name'], FT0RECOtask['name']], tf=tf, cwd=timeframeworkdir, lab=["RECO"], mem='8000', relative_cpu=3/8)
ITSTPCMATCHtask=createTask(name='itstpcMatch_'+str(tf), needs=[TPCRECOtask['name'], ITSRECOtask['name'], FT0RECOtask['name'] if isActive("FT0") else None], tf=tf, cwd=timeframeworkdir, lab=["RECO"], mem='8000', relative_cpu=3/8)
ITSTPCMATCHtask["cmd"] = task_finalizer([
'${O2_ROOT}/bin/o2-tpcits-match-workflow',
getDPL_global_options(bigshm=True),
' --tpc-track-reader tpctracks.root',
'--tpc-native-cluster-reader \"--infile tpc-native-clusters.root\"',
'--use-ft0',
'--use-ft0' if isActive("FT0") else None,
putConfigValues(['MFTClustererParam',
'ITSCATrackerParam',
'tpcitsMatch',
Expand Down Expand Up @@ -1468,7 +1468,7 @@ def getDigiTaskName(det):
'trackTuneParams'], tpcLocalCFreco),
' --track-sources ' + toftracksrcdefault,
(' --combine-devices','')[args.no_combine_dpl_devices],
tofusefit,
tofusefit if isActive("FT0") else None,
tpc_corr_scaling_options,
tpc_corr_options_mc
]
Expand All @@ -1493,7 +1493,8 @@ def getDigiTaskName(det):
'MFTClustererParam']),
('','--disable-mc')[args.no_mc_labels],
('','--run-assessment')[args.mft_assessment_full]])
workflow['stages'].append(MFTRECOtask)
if isActive("MFT"):
workflow['stages'].append(MFTRECOtask)

# MCH reco: needing access to kinematics ... so some extra logic needed here
mchreconeeds = [getDigiTaskName("MCH")]
Expand Down Expand Up @@ -1614,7 +1615,7 @@ def getDigiTaskName(det):

#<--------- MFT-MCH forward matching
forwardmatchneeds = [MCHRECOtask['name'],
MFTRECOtask['name'],
MFTRECOtask['name'] if isActive("MFT") else None,
MCHMIDMATCHtask['name'] if isActive("MID") else None]
MFTMCHMATCHtask = createTask(name='mftmchMatch_'+str(tf), needs=forwardmatchneeds, tf=tf, cwd=timeframeworkdir, lab=["RECO"], mem='1500')
MFTMCHMATCHtask['cmd'] = task_finalizer(
Expand Down Expand Up @@ -1877,21 +1878,22 @@ def remove_json_prefix(path):
### MFT

# to be enabled once MFT Digits should run 5 times with different configurations
for flp in range(5):
addQCPerTF(taskName='mftDigitsQC' + str(flp),
needs=[getDigiTaskName("MFT")],
readerCommand='o2-qc-mft-digits-root-file-reader --mft-digit-infile=mftdigits.root',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/mft-digits-' + str(flp) + '.json',
objectsFile='mftDigitsQC.root')
addQCPerTF(taskName='mftClustersQC',
if isActive("MFT"):
for flp in range(5):
addQCPerTF(taskName='mftDigitsQC' + str(flp),
needs=[getDigiTaskName("MFT")],
readerCommand='o2-qc-mft-digits-root-file-reader --mft-digit-infile=mftdigits.root',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/mft-digits-' + str(flp) + '.json',
objectsFile='mftDigitsQC.root')
addQCPerTF(taskName='mftClustersQC',
needs=[MFTRECOtask['name']],
readerCommand='o2-global-track-cluster-reader --track-types none --cluster-types MFT',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/mft-clusters.json')
addQCPerTF(taskName='mftTracksQC',
addQCPerTF(taskName='mftTracksQC',
needs=[MFTRECOtask['name']],
readerCommand='o2-global-track-cluster-reader --track-types MFT --cluster-types MFT',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/mft-tracks.json')
addQCPerTF(taskName='mftMCTracksQC',
addQCPerTF(taskName='mftMCTracksQC',
needs=[MFTRECOtask['name']],
readerCommand='o2-global-track-cluster-reader --track-types MFT --cluster-types MFT',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/mft-tracks-mc.json')
Expand Down Expand Up @@ -1962,22 +1964,25 @@ def remove_json_prefix(path):
readerCommand='o2-emcal-cell-reader-workflow --infile emccells.root | o2-ctp-digit-reader --inputfile ctpdigits.root --disable-mc',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/emc-bc-task.json')
### FT0
addQCPerTF(taskName='RecPointsQC',
needs=[FT0RECOtask['name']],
readerCommand='o2-ft0-recpoints-reader-workflow --infile o2reco_ft0.root',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/ft0-reconstruction-config.json')
if isActive("FT0"):
addQCPerTF(taskName='RecPointsQC',
needs=[FT0RECOtask['name']],
readerCommand='o2-ft0-recpoints-reader-workflow --infile o2reco_ft0.root',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/ft0-reconstruction-config.json')

### FV0
addQCPerTF(taskName='FV0DigitsQC',
needs=[getDigiTaskName("FV0")],
readerCommand='o2-fv0-digit-reader-workflow --fv0-digit-infile fv0digits.root',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/fv0-digits.json')
if isActive("FV0"):
addQCPerTF(taskName='FV0DigitsQC',
needs=[getDigiTaskName("FV0")],
readerCommand='o2-fv0-digit-reader-workflow --fv0-digit-infile fv0digits.root',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/fv0-digits.json')

### FDD
addQCPerTF(taskName='FDDRecPointsQC',
needs=[FDDRECOtask['name']],
readerCommand='o2-fdd-recpoints-reader-workflow --fdd-recpoints-infile o2reco_fdd.root',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/fdd-recpoints.json')
if isActive("FDD"):
addQCPerTF(taskName='FDDRecPointsQC',
needs=[FDDRECOtask['name']],
readerCommand='o2-fdd-recpoints-reader-workflow --fdd-recpoints-infile o2reco_fdd.root',
configFilePath='json://${O2DPG_ROOT}/MC/config/QC/json/fdd-recpoints.json')

### GLO + RECO
addQCPerTF(taskName='vertexQC',
Expand Down Expand Up @@ -2079,7 +2084,9 @@ def remove_json_prefix(path):
tpctsneeds = [ TPCRECOtask['name'],
ITSTPCMATCHtask['name'],
TOFTPCMATCHERtask['name'],
PVFINDERtask['name']
FT0RECOtask['name'],
PVFINDERtask['name'],
TRDTRACKINGtask2['name']
]
TPCTStask = createTask(name='tpctimeseries_'+str(tf), needs=tpctsneeds, tf=tf, cwd=timeframeworkdir, lab=["RECO"], mem='2000', cpu='1')
TPCTStask['cmd'] = 'o2-global-track-cluster-reader --disable-mc --cluster-types "FT0,TOF,TPC" --track-types "ITS,TPC,ITS-TPC,ITS-TPC-TOF,ITS-TPC-TRD-TOF"'
Expand Down