DPL: provide a --spawners <N> option (#5881)

ktf · web-flow · commit 282b041f52eb · 2021-04-08T10:09:47.000+02:00
Similar to --readers allows creating &lt;N&gt; spawners which work
in a time-pipelined way.
diff --git a/Framework/Core/src/WorkflowCustomizationHelpers.cxx b/Framework/Core/src/WorkflowCustomizationHelpers.cxx
@@ -32,6 +32,7 @@ namespace o2::framework
 std::vector<ConfigParamSpec> WorkflowCustomizationHelpers::requiredWorkflowOptions()
 {
   return std::vector<ConfigParamSpec>{{ConfigParamSpec{"readers", VariantType::Int64, 1ll, {"number of parallel readers to use"}},
+                                       ConfigParamSpec{"spawners", VariantType::Int64, 1ll, {"number of parallel spawners to use"}},
                                        ConfigParamSpec{"pipeline", VariantType::String, "", {"override default pipeline size"}},
                                        ConfigParamSpec{"clone", VariantType::String, "", {"clone processors from a template"}},
                                        ConfigParamSpec{"workflow-suffix", VariantType::String, "", {"suffix to add to all dataprocessors"}},
diff --git a/Framework/Core/src/WorkflowHelpers.cxx b/Framework/Core/src/WorkflowHelpers.cxx
@@ -409,7 +409,7 @@ void WorkflowHelpers::injectServiceDevices(WorkflowSpec& workflow, ConfigContext
   }
 
   if (aodSpawner.outputs.empty() == false) {
-    extraSpecs.push_back(aodSpawner);
+    extraSpecs.push_back(timePipeline(aodSpawner, ctx.options().get<int64_t>("spawners")));
   }
 
   if (indexBuilder.outputs.empty() == false) {

Original file line number	Diff line number	Diff line change
`@@ -32,6 +32,7 @@ namespace o2::framework`
`32`	`32`	`std::vector<ConfigParamSpec> WorkflowCustomizationHelpers::requiredWorkflowOptions()`
`33`	`33`	`{`
`34`	`34`	`return std::vector<ConfigParamSpec>{{ConfigParamSpec{"readers", VariantType::Int64, 1ll, {"number of parallel readers to use"}},`
	`35`	`+ ConfigParamSpec{"spawners", VariantType::Int64, 1ll, {"number of parallel spawners to use"}},`
`35`	`36`	`ConfigParamSpec{"pipeline", VariantType::String, "", {"override default pipeline size"}},`
`36`	`37`	`ConfigParamSpec{"clone", VariantType::String, "", {"clone processors from a template"}},`
`37`	`38`	`ConfigParamSpec{"workflow-suffix", VariantType::String, "", {"suffix to add to all dataprocessors"}},`
Original file line number	Diff line number	Diff line change
`@@ -409,7 +409,7 @@ void WorkflowHelpers::injectServiceDevices(WorkflowSpec& workflow, ConfigContext`
`409`	`409`	`}`
`410`	`410`
`411`	`411`	`if (aodSpawner.outputs.empty() == false) {`
`412`		`- extraSpecs.push_back(aodSpawner);`
	`412`	`+ extraSpecs.push_back(timePipeline(aodSpawner, ctx.options().get<int64_t>("spawners")));`
`413`	`413`	`}`
`414`	`414`
`415`	`415`	`if (indexBuilder.outputs.empty() == false) {`