Add error log entry for maintainpull failed (#2129)

Missed a spot where we should add a error log entry for maintain pull failing
PeerDB-io · Oct 18, 2024 · 95d160e · 95d160e
1 parent 939cafb
commit 95d160e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -312,6 +312,7 @@ func (a *FlowableActivity) MaintainPull(
 				a.CdcCacheRw.Lock()
 				delete(a.CdcCache, sessionID)
 				a.CdcCacheRw.Unlock()
+				a.Alerter.LogFlowError(ctx, config.FlowJobName, err)
 				return temporal.NewNonRetryableApplicationError("connection to source down", "disconnect", err)
 			}
 		case <-done: