[Common] Update workflow definition to check for existing tables

Common/TableProducer/Converters/tracksExtraV002Converter.cxx

@@ -1,4 +1,4 @@
 // 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.
 //
@@ -8,7 +8,7 @@
 // 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.
 
 #include <Framework/AnalysisDataModel.h>
 #include <Framework/AnalysisHelpers.h>
 #include <Framework/AnalysisTask.h>
@@ -22,7 +22,7 @@
 using namespace o2::framework;
 
 struct TracksExtraV002Converter {
   Produces<aod::StoredTracksExtra_002> tracksExtra_002;
 
   void init(InitContext const&)
   {
@@ -40,13 +40,13 @@
     for (const auto& track0 : tracksExtra_000) {
 
       uint32_t itsClusterSizes = 0;
       for (int layer = 0; layer < 7; layer++) {
         if (track0.itsClusterMap() & (1 << layer)) {
           itsClusterSizes |= (0xf << (layer * 4));
         }
       }
 
       int8_t TPCNClsFindableMinusPID = 0;
 
       tracksExtra_002(track0.tpcInnerParam(),
                       track0.flags(),
@@ -78,7 +78,7 @@
 
     for (const auto& track1 : tracksExtra_001) {
 
       int8_t TPCNClsFindableMinusPID = 0;
 
       tracksExtra_002(track1.tpcInnerParam(),
                       track1.flags(),
@@ -108,13 +108,29 @@
 
 /// Spawn the extended table for TracksExtra002 to avoid the call to the internal spawner and a consequent circular dependency
 struct TracksExtraSpawner {
   Spawns<aod::TracksExtra_002> tracksExtra_002;
 };
 
 WorkflowSpec defineDataProcessing(ConfigContext const& cfgc)
 {
-  return WorkflowSpec{
-    adaptAnalysisTask<TracksExtraV002Converter>(cfgc),
-    adaptAnalysisTask<TracksExtraSpawner>(cfgc),
-  };
+  auto workflow = WorkflowSpec{};
+  // Check if 'aod-metadata-tables' option is available in the config context
+  if (cfgc.options().hasOption("aod-metadata-tables")) {
+    LOG(debug) << "'aod-metadata-tables' option found in the config context, checking for existing tables";
+    // Get the list of tables from the config context
+    const std::vector<std::string> tables = cfgc.options().get<std::vector<std::string>>("aod-metadata-tables");
+    // If the table is already found, do not add the converter and spawner
+    if (std::find(tables.begin(), tables.end(), "O2trackextra_002") == tables.end()) {
+      LOG(debug) << "Adding TracksExtraV002Converter and TracksExtraSpawner to the workflow";
+      workflow.push_back(adaptAnalysisTask<TracksExtraV002Converter>(cfgc));
+      workflow.push_back(adaptAnalysisTask<TracksExtraSpawner>(cfgc));
+    } else {
+      LOG(debug) << "Table O2trackextra_002 already found, not adding converter and spawner";
+    }
+  } else {
+    LOG(debug) << "'aod-metadata-tables' option not found in the config context, adding converter and spawner by default";
+    workflow.push_back(adaptAnalysisTask<TracksExtraV002Converter>(cfgc));
+    workflow.push_back(adaptAnalysisTask<TracksExtraSpawner>(cfgc));
+  }
+  return workflow;
 }