[QC-953] mergers can receive labels through config (#12354)

Author: Barthelemy

Framework/Core/include/Framework/DataProcessorLabel.h

@@ -23,6 +23,16 @@ struct DataProcessorLabel {
   {
     return value == rhs.value;
   }
+
+  bool operator<(const DataProcessorLabel& rhs) const
+  {
+    return value < rhs.value;
+  }
+
+  bool operator>(const DataProcessorLabel& rhs) const
+  {
+    return value > rhs.value;
+  }
 };
 } // namespace o2::framework
 #endif // O2_FRAMEWORK_DATAPROCESSORLABEL_H_

Utilities/Mergers/include/Mergers/MergerConfig.h

@@ -20,6 +20,7 @@
 #include <string>
 #include <vector>
 #include <variant>
+#include "Framework/DataProcessorLabel.h"
 
 namespace o2::mergers
 {
@@ -95,7 +96,7 @@ struct MergerConfig {
   std::string monitoringUrl = "infologger:///debug?qc";
   std::string detectorName = "TST";
   ConfigEntry<ParallelismType> parallelismType = {ParallelismType::SplitInputs};
-  bool expendable = false;
+  std::vector<o2::framework::DataProcessorLabel> labels;
 };
 
 } // namespace o2::mergers

Utilities/Mergers/src/MergerBuilder.cxx

@@ -117,10 +117,9 @@ framework::DataProcessorSpec MergerBuilder::buildSpec()
 
   merger.inputs.push_back({"timer-publish", "TMR", mergerDataDescription(mName), mergerSubSpec(mLayer, mId), framework::Lifetime::Timer, timerSpecs(timers)});
   merger.labels.push_back(mergerLabel());
-  if (mConfig.expendable) {
-    framework::DataProcessorLabel expendableLabel = {"expendable"};
-    merger.labels.emplace_back(expendableLabel);
-  }
+  merger.labels.insert(merger.labels.end(), mConfig.labels.begin(), mConfig.labels.end());
+  std::sort(merger.labels.begin(), merger.labels.end());
+  merger.labels.erase(std::unique(merger.labels.begin(), merger.labels.end()), merger.labels.end());
   merger.maxInputTimeslices = mTimePipeline;
 
   return std::move(merger);