prevent duplicate send in case of transform error (#4191)

mmetc · web-flow · commit 795222e73625 · 2026-01-16T22:06:48.000+01:00
diff --git a/pkg/acquisition/acquisition.go b/pkg/acquisition/acquisition.go
@@ -407,11 +407,13 @@ func transform(
 			if err != nil {
 				logger.Errorf("while running transform expression: %s, sending event as-is", err)
 				output <- evt
+				continue
 			}
 
 			if out == nil {
 				logger.Errorf("transform expression returned nil, sending event as-is")
 				output <- evt
+				continue
 			}
 
 			switch v := out.(type) {

Original file line number	Diff line number	Diff line change
`@@ -407,11 +407,13 @@ func transform(`
`407`	`407`	`if err != nil {`
`408`	`408`	`logger.Errorf("while running transform expression: %s, sending event as-is", err)`
`409`	`409`	`output <- evt`
	`410`	`+ continue`
`410`	`411`	`}`
`411`	`412`
`412`	`413`	`if out == nil {`
`413`	`414`	`logger.Errorf("transform expression returned nil, sending event as-is")`
`414`	`415`	`output <- evt`
	`416`	`+ continue`
`415`	`417`	`}`
`416`	`418`
`417`	`419`	`switch v := out.(type) {`