fix(sync-flow): alert on destination connector failures (#2177)

PeerDB-io · Oct 23, 2024 · f82591a · f82591a
1 parent 724f1bc
commit f82591a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flow/activities/flowable_core.go b/flow/activities/flowable_core.go
@@ -144,6 +144,7 @@ func syncCore[TPull connectors.CDCPullConnectorCore, TSync connectors.CDCSyncCon
 		return dstConn.GetLastOffset(ctx, config.FlowJobName)
 	}()
 	if err != nil {
+		a.Alerter.LogFlowError(ctx, flowName, err)
 		return nil, err
 	}