[core] propagate pdp_beam_type as FairMQ property to ODC tasks

needed by QC tasks OCTRL-976
AliceO2Group · Jan 16, 2025 · 0fe8c3f · 0fe8c3f
1 parent b52f397
commit 0fe8c3f
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/core/integration/odc/plugin.go b/core/integration/odc/plugin.go
@@ -1229,6 +1229,15 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
 				Warn("could not get get variable force_run_as_raw from environment context")
 		}
 
+		pdpBeamType, ok := varStack["pdp_beam_type"]
+		if ok {
+			arguments["pdp_beam_type"] = pdpBeamType
+		} else {
+			log.WithField("partition", envId).
+				WithField("call", "Configure").
+				Warn("could not get get variable pdp_beam_type from environment context")
+		}
+
 		detectorListS, ok := varStack["detectors"]
 		if ok {
 			detectorsSlice, err := p.parseDetectors(detectorListS)