LogFlowError on mysql ConnectionActive failure (#4521)

serprex · web-flow · commit 4c85a9d691b9 · 2026-06-30T13:47:49.000-07:00
Avoids stuck mirror being silent in error logs
diff --git a/flow/activities/flowable_core.go b/flow/activities/flowable_core.go
@@ -149,7 +149,7 @@ func pullAndSyncCore[TPull connectors.CDCPullConnectorCore, TSync connectors.CDC
 	}
 
 	if err := srcConn.ConnectionActive(ctx); err != nil {
-		return nil, fmt.Errorf("connection to source down: %w", err)
+		return nil, a.Alerter.LogFlowError(ctx, flowName, fmt.Errorf("connection to source down: %w", err))
 	}
 
 	batchSize := options.BatchSize

Original file line number	Diff line number	Diff line change
`@@ -149,7 +149,7 @@ func pullAndSyncCore[TPull connectors.CDCPullConnectorCore, TSync connectors.CDC`
`149`	`149`	`}`
`150`	`150`
`151`	`151`	`if err := srcConn.ConnectionActive(ctx); err != nil {`
`152`		`- return nil, fmt.Errorf("connection to source down: %w", err)`
	`152`	`+ return nil, a.Alerter.LogFlowError(ctx, flowName, fmt.Errorf("connection to source down: %w", err))`
`153`	`153`	`}`
`154`	`154`
`155`	`155`	`batchSize := options.BatchSize`