Integrate FV0 workflow

AliceO2Group · Sep 13, 2021 · baf36c7 · baf36c7
1 parent 9f973cf
commit baf36c7
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/MC/bin/o2dpg_sim_workflow.py b/MC/bin/o2dpg_sim_workflow.py
@@ -607,6 +607,10 @@ def createRestDigiTask(name, det='ALLSMALLER'):
    FDDRECOtask['cmd'] = 'o2-fdd-reco-workflow ' + getDPL_global_options()
    workflow['stages'].append(FDDRECOtask)
 
+   FV0RECOtask = createTask(name='fv0reco_'+str(tf), needs=[det_to_digitask["FV0"]['name']], tf=tf, cwd=timeframeworkdir, lab=["RECO"], mem='1500')
+   FV0RECOtask['cmd'] = 'o2-fv0-reco-workflow ' + getDPL_global_options()
+   workflow['stages'].append(FV0RECOtask)
+
    pvfinderneeds = [ITSTPCMATCHtask['name'], FT0RECOtask['name'], TOFTPCMATCHERtask['name'], MFTRECOtask['name'], MCHRECOtask['name'], TRDTRACKINGtask['name'], FDDRECOtask['name'], MIDRECOtask['name']]
    PVFINDERtask = createTask(name='pvfinder_'+str(tf), needs=pvfinderneeds, tf=tf, cwd=timeframeworkdir, lab=["RECO"], cpu=NWORKERS, mem='4000')
    PVFINDERtask['cmd'] = 'o2-primary-vertexing-workflow ' + getDPL_global_options()
@@ -671,7 +675,7 @@ def createRestDigiTask(name, det='ALLSMALLER'):
   # -----------
   # produce AOD
   # -----------
-   aodneeds = [PVFINDERtask['name'], SVFINDERtask['name'], TOFRECOtask['name'], TRDTRACKINGtask['name']]
+   aodneeds = [PVFINDERtask['name'], SVFINDERtask['name'], TOFRECOtask['name'], TRDTRACKINGtask['name'], FV0RECOtask['name']]
    if usebkgcache:
      aodneeds += [ BKG_KINEDOWNLOADER_TASK['name'] ]