Undo flow error on connection to source down (#4066)

ilidemi · web-flow · commit a751ad574e7f · 2026-03-16T21:05:40.000-07:00
Introduced in #3996 Turned out to be too noisy so we need to solve that first
diff --git a/flow/activities/flowable_core.go b/flow/activities/flowable_core.go
@@ -142,7 +142,7 @@ func syncCore[TPull connectors.CDCPullConnectorCore, TSync connectors.CDCSyncCon
 	}
 
 	if err := srcConn.ConnectionActive(ctx); err != nil {
-		return nil, a.Alerter.LogFlowError(ctx, flowName, fmt.Errorf("connection to source down: %w", err))
+		return nil, fmt.Errorf("connection to source down: %w", err)
 	}
 
 	batchSize := options.BatchSize

Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,7 @@ func syncCore[TPull connectors.CDCPullConnectorCore, TSync connectors.CDCSyncCon`
`142`	`142`	`}`
`143`	`143`
`144`	`144`	`if err := srcConn.ConnectionActive(ctx); err != nil {`
`145`		`- return nil, a.Alerter.LogFlowError(ctx, flowName, fmt.Errorf("connection to source down: %w", err))`
	`145`	`+ return nil, fmt.Errorf("connection to source down: %w", err)`
`146`	`146`	`}`
`147`	`147`
`148`	`148`	`batchSize := options.BatchSize`