[core] Send TRG to ODC detector list if ctp_readout_enabled

teo · teo · commit cbea88687174 · 2022-10-17T16:52:06.000+02:00
diff --git a/core/integration/odc/plugin.go b/core/integration/odc/plugin.go
@@ -382,6 +382,13 @@ func (p *Plugin) ObjectStack(varStack map[string]string) (stack map[string]inter
 					Error("cannot parse general detector list")
 				return
 			}
+
+			// Special case: if the detector list is "default" and ctp_readout_enabled==true, we include TRG
+			ctpReadoutEnabled := "false"
+			ctpReadoutEnabled, ok = varStack["ctp_readout_enabled"]
+			if ok && strings.ToLower(strings.TrimSpace(ctpReadoutEnabled)) == "true" {
+				detectorsSlice = append(detectorsSlice, "TRG")
+			}
 			pdpDetectorList = strings.Join(detectorsSlice, ",")
 		}
 		accumulator = append(accumulator, fmt.Sprintf("WORKFLOW_DETECTORS='%s'", strings.TrimSpace(pdpDetectorList)))

Original file line number	Diff line number	Diff line change
`@@ -382,6 +382,13 @@ func (p *Plugin) ObjectStack(varStack map[string]string) (stack map[string]inter`
`382`	`382`	`Error("cannot parse general detector list")`
`383`	`383`	`return`
`384`	`384`	`}`
	`385`	`+`
	`386`	`+ // Special case: if the detector list is "default" and ctp_readout_enabled==true, we include TRG`
	`387`	`+ ctpReadoutEnabled := "false"`
	`388`	`+ ctpReadoutEnabled, ok = varStack["ctp_readout_enabled"]`
	`389`	`+ if ok && strings.ToLower(strings.TrimSpace(ctpReadoutEnabled)) == "true" {`
	`390`	`+ detectorsSlice = append(detectorsSlice, "TRG")`
	`391`	`+ }`
`385`	`392`	`pdpDetectorList = strings.Join(detectorsSlice, ",")`
`386`	`393`	`}`
`387`	`394`	`accumulator = append(accumulator, fmt.Sprintf("WORKFLOW_DETECTORS='%s'", strings.TrimSpace(pdpDetectorList)))`