DPL: allow adding suffix to all dataprocessors in a workflow

Author: ktf

Framework/Core/include/Framework/runDataProcessing.h

@@ -105,6 +105,9 @@ void overridePipeline(o2::framework::ConfigContext& ctx, std::vector<o2::framewo
 /// Helper used to customize a workflow via a template data processor
 void overrideCloning(o2::framework::ConfigContext& ctx, std::vector<o2::framework::DataProcessorSpec>& workflow);
 
+/// Helper used to customize the workflow via a global suffix.
+void overrideSuffix(o2::framework::ConfigContext& ctx, std::vector<o2::framework::DataProcessorSpec>& workflow);
+
 // This comes from the framework itself. This way we avoid code duplication.
 int doMain(int argc, char** argv, o2::framework::WorkflowSpec const& specs,
            std::vector<o2::framework::ChannelConfigurationPolicy> const& channelPolicies,
@@ -131,6 +134,7 @@ int main(int argc, char** argv)
     workflowOptions.push_back(ConfigParamSpec{"readers", VariantType::Int64, 1ll, {"number of parallel readers to use"}});
     workflowOptions.push_back(ConfigParamSpec{"pipeline", VariantType::String, "", {"override default pipeline size"}});
     workflowOptions.push_back(ConfigParamSpec{"clone", VariantType::String, "", {"clone processors from a template"}});
+    workflowOptions.push_back(ConfigParamSpec{"workflow-suffix", VariantType::String, "", {"suffix to add to all dataprocessors"}});
 
     // options for AOD rate limiting
     workflowOptions.push_back(ConfigParamSpec{"aod-memory-rate-limit", VariantType::Int64, 0LL, {"Rate limit AOD processing based on memory"}});
@@ -176,8 +180,9 @@ int main(int argc, char** argv)
     ConfigParamRegistry workflowOptionsRegistry(std::move(workflowOptionsStore));
     ConfigContext configContext(workflowOptionsRegistry, argc, argv);
     o2::framework::WorkflowSpec specs = defineDataProcessing(configContext);
-    overridePipeline(configContext, specs);
     overrideCloning(configContext, specs);
+    overrideSuffix(configContext, specs);
+    overridePipeline(configContext, specs);
     for (auto& spec : specs) {
       UserCustomizationsHelper::userDefinedCustomization(spec.requiredServices, 0);
     }

Framework/Core/src/runDataProcessing.cxx

@@ -1388,6 +1388,17 @@ bool isOutputToPipe()
   return ((s.st_mode & S_IFIFO) != 0);
 }
 
+void overrideSuffix(ConfigContext& ctx, WorkflowSpec& workflow)
+{
+  auto suffix = ctx.options().get<std::string>("workflow-suffix");
+  if (suffix.empty()) {
+    return;
+  }
+  for (auto& processor : workflow) {
+    processor.name = processor.name + suffix;
+  }
+}
+
 void overrideCloning(ConfigContext& ctx, WorkflowSpec& workflow)
 {
   struct CloningSpec {