Skip to content

Commit 5ff7ecc

Browse files
knopers8justonedev1
authored andcommitted
[core] OCTRL-921 Add env ID to DCS SOR and EOR requests
1 parent 89386ba commit 5ff7ecc

File tree

4 files changed

+171
-145
lines changed

4 files changed

+171
-145
lines changed

core/integration/dcs/plugin.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1238,9 +1238,10 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
12381238

12391239
// Preparing the per-detector request payload
12401240
in := dcspb.SorRequest{
1241-
RunType: rt,
1242-
RunNumber: int32(runNumber64),
1243-
Detectors: make([]*dcspb.DetectorOperationRequest, len(dcsDetectors)),
1241+
RunType: rt,
1242+
RunNumber: int32(runNumber64),
1243+
Detectors: make([]*dcspb.DetectorOperationRequest, len(dcsDetectors)),
1244+
PartitionId: envId,
12441245
}
12451246
for i, dcsDet := range dcsDetectors {
12461247
ecsDet := dcsToEcsDetector(dcsDet)
@@ -1770,8 +1771,9 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
17701771

17711772
// Preparing the per-detector request payload
17721773
in := dcspb.EorRequest{
1773-
RunNumber: int32(runNumber64),
1774-
Detectors: make([]*dcspb.DetectorOperationRequest, len(dcsDetectors)),
1774+
RunNumber: int32(runNumber64),
1775+
Detectors: make([]*dcspb.DetectorOperationRequest, len(dcsDetectors)),
1776+
PartitionId: envId,
17751777
}
17761778
for i, dcsDet := range dcsDetectors {
17771779
ecsDet := dcsToEcsDetector(dcsDet)

0 commit comments

Comments
 (0)