truncate errors

PeerDB-io · Oct 22, 2023 · 7216f9a · 7216f9a
1 parent e340e46
commit 7216f9a
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -102,6 +102,16 @@ func (s *CDCFlowState) TruncateProgress() {
 	if len(s.NormalizeFlowStatuses) > 10 {
 		s.NormalizeFlowStatuses = s.NormalizeFlowStatuses[len(s.NormalizeFlowStatuses)-10:]
 	}
+
+	if s.SyncFlowErrors != nil {
+		fmt.Println("SyncFlowErrors: ", s.SyncFlowErrors)
+		s.SyncFlowErrors = nil
+	}
+
+	if s.NormalizeFlowErrors != nil {
+		fmt.Println("NormalizeFlowErrors: ", s.NormalizeFlowErrors)
+		s.NormalizeFlowErrors = nil
+	}
 }
 
 func (s *CDCFlowState) SendWALHeartbeat(ctx workflow.Context, cfg *protos.FlowConnectionConfigs) error {