diff --git a/PWGJE/TableProducer/CMakeLists.txt b/PWGJE/TableProducer/CMakeLists.txt index f0d91e9c98b..3e7510f56b9 100644 --- a/PWGJE/TableProducer/CMakeLists.txt +++ b/PWGJE/TableProducer/CMakeLists.txt @@ -105,3 +105,8 @@ o2physics_add_dpl_workflow(emcal-cluster-hadronic-correction-task SOURCES emcalClusterHadronicCorrectionTask.cxx PUBLIC_LINK_LIBRARIES O2::Framework O2Physics::AnalysisCore O2::DetectorsBase O2::EMCALBase O2::EMCALReconstruction COMPONENT_NAME Analysis) + +o2physics_add_dpl_workflow(slim-tables-producer + SOURCES slimTablesProducer.cxx + PUBLIC_LINK_LIBRARIES O2::Framework O2Physics::AnalysisCore + COMPONENT_NAME Analysis) diff --git a/PWGJE/TableProducer/slimTablesProducer.cxx b/PWGJE/TableProducer/slimTablesProducer.cxx new file mode 100644 index 00000000000..836f557a477 --- /dev/null +++ b/PWGJE/TableProducer/slimTablesProducer.cxx @@ -0,0 +1,238 @@ +// Copyright 2019-2020 CERN and copyright holders of ALICE O2. +// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders. +// All rights not expressly granted are reserved. +// +// This software is distributed under the terms of the GNU General Public +// License v3 (GPL Version 3), copied verbatim in the file "COPYING". +// +// In applying this license CERN does not waive the privileges and immunities +// granted to it by virtue of its status as an Intergovernmental Organization +// or submit itself to any jurisdiction. + +/// \file slimTablesProducer.cxx +/// \brief Task to produce a reduced version of Tables for tracks, collisions, mcparticles and mccollisions. +/// \author Millot Louise + +#include "PWGJE/Core/JetDerivedDataUtilities.h" +#include "PWGJE/DataModel/Jet.h" +#include "PWGJE/DataModel/JetReducedData.h" + +#include "Common/Core/TrackSelection.h" +#include "Common/Core/TrackSelectionDefaults.h" +#include "Common/DataModel/TrackSelectionTables.h" + +#include +#include +#include +#include +#include +#include +#include + +#include + +#include +#include + +namespace o2::aod +{ +namespace slimcollision +{ +DECLARE_SOA_COLUMN(Weight, weight, float); +} +DECLARE_SOA_TABLE(SlimCollisions, "AOD", "SlimCollisions", + o2::soa::Index<>, + o2::aod::collision::PosZ, + o2::aod::collision::CollisionTime, + slimcollision::Weight); +using SlimCollision = SlimCollisions::iterator; +namespace slmccollision +{ +DECLARE_SOA_COLUMN(McWeight, mcWeight, float); +} +DECLARE_SOA_TABLE(SlMcCollisions, "AOD", "SlMcCollisions", + o2::soa::Index<>, + o2::aod::mccollision::PosZ, + slmccollision::McWeight); +using SlMcCollision = SlMcCollisions::iterator; +namespace slimtracks +{ +DECLARE_SOA_INDEX_COLUMN(SlimCollision, slimCollision); +DECLARE_SOA_COLUMN(Px, px, float); +DECLARE_SOA_COLUMN(Py, py, float); +DECLARE_SOA_COLUMN(Pz, pz, float); +DECLARE_SOA_COLUMN(E, e, float); +} // namespace slimtracks +DECLARE_SOA_TABLE(SlimTracks, "AOD", "SlimTracks", + o2::soa::Index<>, + slimtracks::SlimCollisionId, + slimtracks::Px, + slimtracks::Py, + slimtracks::Pz, + slimtracks::E); +using SlimTrack = SlimTracks::iterator; +namespace slimparticles +{ +DECLARE_SOA_INDEX_COLUMN(SlMcCollision, slMcCollision); +DECLARE_SOA_COLUMN(Px, px, float); +DECLARE_SOA_COLUMN(Py, py, float); +DECLARE_SOA_COLUMN(Pz, pz, float); +DECLARE_SOA_COLUMN(E, e, float); +} // namespace slimparticles +DECLARE_SOA_TABLE(SlimParticles, "AOD", "SlimParticles", + o2::soa::Index<>, + slimparticles::SlMcCollisionId, + slimparticles::Px, + slimparticles::Py, + slimparticles::Pz, + slimparticles::E); +using SlimParticle = SlimParticles::iterator; +} // namespace o2::aod + +using namespace o2; +using namespace o2::framework; +using namespace o2::framework::expressions; + +struct SlimTablesProducer { + + HistogramRegistry histos{"histos", {}, OutputObjHandlingPolicy::AnalysisObject}; + Configurable checkCentFT0M{"checkCentFT0M", false, "0: centFT0C as default, 1: use centFT0M estimator"}; + Configurable centralityMin{"centralityMin", -999, ""}; + Configurable centralityMax{"centralityMax", 999, ""}; + Configurable minPt{"minPt", 0.15, "min pT to save"}; + Configurable maxPt{"maxPt", 200.0, "max pT to save"}; + Configurable minEta{"minEta", -0.9, "min eta to save"}; + Configurable maxEta{"maxEta", 0.9, "max eta to save"}; + Configurable vertexZCut{"vertexZCut", 10.0f, "Accepted z-vertex range"}; + Configurable eventSelections{"eventSelections", "sel8", "Event selection"}; + Configurable trackSelections{"trackSelections", "globalTracks", "set track selections; other option: uniformTracks"}; + Configurable minTPCNClsCrossedRows{"minTPCNClsCrossedRows", 80, "min TPC crossed rows"}; + Configurable skipMBGapEvents{"skipMBGapEvents", false, "flag to choose to reject min. bias gap events; jet-level rejection can also be applied at the jet finder level for jets only, here rejection is applied for collision and track process functions for the first time, and on jets in case it was set to false at the jet finder level"}; + Configurable applyRCTSelections{"applyRCTSelections", true, "decide to apply RCT selections"}; + + std::vector eventSelectionBits; + int trackSelection = -1; + bool doSumw2 = false; + + void init(InitContext&) + { + doSumw2 = skipMBGapEvents; // true or false : storage of square erros when jet-jet + + AxisSpec centralityAxis = {1200, -10., 110., "Centrality"}; + + histos.add("h_collisions", "event status;event status;entries", {HistType::kTH1F, {{4, 0.0, 4.0}}}); + histos.add("h2_centrality_collisions", "event status vs. centrality;entries;centrality", {HistType::kTH2F, {centralityAxis, {4, 0.0, 4.0}}}, doSumw2); + auto hColl = histos.get(HIST("h_collisions")); + hColl->GetXaxis()->SetBinLabel(1, "All"); + hColl->GetXaxis()->SetBinLabel(2, "eventSelection"); + + histos.add("h_mcCollMCD_counts_weight", "MC event status;event status;weighted entries", {HistType::kTH1F, {{5, 0.0, 5.0}}}); + auto hMCD = histos.get(HIST("h_mcCollMCD_counts_weight")); + hMCD->GetXaxis()->SetBinLabel(1, "All"); + hMCD->GetXaxis()->SetBinLabel(2, "eventSelectionBits + skipMBGapEvents + applyRCTSelections "); + + histos.add("h_mcCollMCP_counts_weight", "MC event status;event status;weighted entries", {HistType::kTH1F, {{7, 0.0, 7.0}}}); + auto hMCP = histos.get(HIST("h_mcCollMCP_counts_weight")); + hMCP->GetXaxis()->SetBinLabel(1, "All"); + hMCP->GetXaxis()->SetBinLabel(2, "mcColl + skipMBGapEvents + applyRCTSelections"); + hMCP->GetXaxis()->SetBinLabel(3, "Zvertex"); + + eventSelectionBits = jetderiveddatautilities::initialiseEventSelectionBits(static_cast(eventSelections)); + trackSelection = jetderiveddatautilities::initialiseTrackSelection(static_cast(trackSelections)); + } + + Produces slimCollisions; + Produces slimMcCollisions; + Produces slimTracks; + Produces slimParticles; + + Filter trackFilter = (aod::jtrack::pt >= minPt && aod::jtrack::pt < maxPt && aod::jtrack::eta > minEta && aod::jtrack::eta < maxEta); + Filter eventCuts = (nabs(aod::jcollision::posZ) < vertexZCut && + (checkCentFT0M ? aod::jcollision::centFT0M : aod::jcollision::centFT0C) >= centralityMin && + (checkCentFT0M ? aod::jcollision::centFT0M : aod::jcollision::centFT0C) < centralityMax); + Filter mcCollisionFilter = (nabs(aod::jmccollision::posZ) < vertexZCut && aod::jmccollision::centFT0M >= centralityMin && aod::jmccollision::centFT0M < centralityMax); // no centFT0C for mccollisions, using centFT0M for both + Filter particleCuts = (aod::jmcparticle::pt >= minPt && aod::jmcparticle::pt < maxPt && aod::jmcparticle::eta > minEta && aod::jmcparticle::eta < maxEta); + + Preslice perCollisionTracks = aod::jtrack::collisionId; + Preslice perMcCollisionParticles = aod::jmcparticle::mcCollisionId; + + void processData(soa::Filtered::iterator const& collision, + soa::Filtered const& tracks) + { + histos.fill(HIST("h_collisions"), 0.5); + float centrality = -1.0; + checkCentFT0M ? centrality = collision.centFT0M() : centrality = collision.centFT0C(); + histos.fill(HIST("h2_centrality_collisions"), centrality, 0.5, 1.0); + if (!jetderiveddatautilities::selectCollision(collision, eventSelectionBits, false, applyRCTSelections)) { + return; + } + histos.fill(HIST("h_collisions"), 1.5); + slimCollisions(collision.posZ(), collision.collisionTime(), 1.0); + auto slimCollIndex = slimCollisions.lastIndex(); + for (const auto& track : tracks) { + if (!jetderiveddatautilities::selectTrack(track, trackSelection)) { + continue; + } + float mass = jetderiveddatautilities::mPion; + float p = track.pt() * std::cosh(track.eta()); + float energy = std::sqrt(p * p + mass * mass); + slimTracks(slimCollIndex, track.px(), track.py(), track.pz(), energy); + } + } + PROCESS_SWITCH(SlimTablesProducer, processData, "process collisions and tracks for data", false); + + void processMC(soa::Filtered const& collisions, + aod::JetMcCollisions const&, // join the weight + soa::Filtered const& tracks, + soa::Filtered const& particles) + { + for (auto const& collision : collisions) { + float eventWeight = collision.weight(); + if (!collision.has_mcCollision()) { + continue; + } + auto mcColl = collision.mcCollision(); // corresponding MC coll + histos.fill(HIST("h_mcCollMCD_counts_weight"), 0.5, eventWeight); + histos.fill(HIST("h_mcCollMCP_counts_weight"), 0.5, eventWeight); + if (!jetderiveddatautilities::selectCollision(collision, eventSelectionBits, skipMBGapEvents, applyRCTSelections)) { + continue; + } + if (!jetderiveddatautilities::selectMcCollision(mcColl, skipMBGapEvents, applyRCTSelections)) { + continue; + } + histos.fill(HIST("h_mcCollMCD_counts_weight"), 1.5, eventWeight); + histos.fill(HIST("h_mcCollMCP_counts_weight"), 1.5, eventWeight); + if (std::abs(mcColl.posZ()) > vertexZCut) + continue; + histos.fill(HIST("h_mcCollMCP_counts_weight"), 2.5, eventWeight); + + float eventMCWeight = mcColl.weight(); + slimCollisions(collision.posZ(), collision.collisionTime(), eventWeight); + auto slimCollIndex = slimCollisions.lastIndex(); + auto slicedTracks = tracks.sliceBy(perCollisionTracks, collision.globalIndex()); // tracks associated to the rec collision + for (const auto& track : slicedTracks) { + if (!jetderiveddatautilities::selectTrack(track, trackSelection)) + continue; + float mass = jetderiveddatautilities::mPion; + float p = track.pt() * std::cosh(track.eta()); + float energy = std::sqrt(p * p + mass * mass); + slimTracks(slimCollIndex, track.px(), track.py(), track.pz(), energy); + } + slimMcCollisions(mcColl.posZ(), eventMCWeight); + auto slimMcCollIndex = slimMcCollisions.lastIndex(); + auto slicedParticles = particles.sliceBy(perMcCollisionParticles, mcColl.globalIndex()); // particles associated to the mc collision + for (const auto& particle : slicedParticles) { + if (!particle.isPhysicalPrimary()) + continue; + slimParticles(slimMcCollIndex, particle.px(), particle.py(), particle.pz(), particle.energy()); + } + } + } + PROCESS_SWITCH(SlimTablesProducer, processMC, "process collisions & tracks, MCcollisions & particles for MC", false); +}; + +WorkflowSpec defineDataProcessing(ConfigContext const& cfgc) +{ + return WorkflowSpec{ + adaptAnalysisTask(cfgc)}; +}