From 6aa8be6030987a6e13092b7d8cfc48fa3f444cc9 Mon Sep 17 00:00:00 2001
From: Piotr Konopka <piotr.jan.konopka@cern.ch>
Date: Mon, 13 Jan 2025 16:56:06 +0100
Subject: [PATCH] [core] propagate pdp_beam_type as FairMQ property to ODC
 tasks

needed by QC tasks

OCTRL-976
---
 core/integration/odc/plugin.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/core/integration/odc/plugin.go b/core/integration/odc/plugin.go
index ea3a7a28..3d3aafb6 100644
--- 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)