[core] OCTRL-921 Add env ID to DCS SOR and EOR requests

AliceO2Group · Sep 18, 2024 · 5ff7ecc · 5ff7ecc
1 parent 89386ba
commit 5ff7ecc
Show file tree

Hide file tree

Showing 4 changed files with 171 additions and 145 deletions.
diff --git a/core/integration/dcs/plugin.go b/core/integration/dcs/plugin.go
@@ -1238,9 +1238,10 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
 
 		// Preparing the per-detector request payload
 		in := dcspb.SorRequest{
-			RunType:   rt,
-			RunNumber: int32(runNumber64),
-			Detectors: make([]*dcspb.DetectorOperationRequest, len(dcsDetectors)),
+			RunType:     rt,
+			RunNumber:   int32(runNumber64),
+			Detectors:   make([]*dcspb.DetectorOperationRequest, len(dcsDetectors)),
+			PartitionId: envId,
 		}
 		for i, dcsDet := range dcsDetectors {
 			ecsDet := dcsToEcsDetector(dcsDet)
@@ -1770,8 +1771,9 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
 
 		// Preparing the per-detector request payload
 		in := dcspb.EorRequest{
-			RunNumber: int32(runNumber64),
-			Detectors: make([]*dcspb.DetectorOperationRequest, len(dcsDetectors)),
+			RunNumber:   int32(runNumber64),
+			Detectors:   make([]*dcspb.DetectorOperationRequest, len(dcsDetectors)),
+			PartitionId: envId,
 		}
 		for i, dcsDet := range dcsDetectors {
 			ecsDet := dcsToEcsDetector(dcsDet)