cdc_flow: cleanup error logging

PeerDB-io · Feb 12, 2024 · c0d46b6 · c0d46b6
1 parent feea44b
commit c0d46b6
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -95,12 +95,12 @@ func (s *CDCFlowWorkflowState) TruncateProgress(logger log.Logger) {
 	}
 
 	if s.SyncFlowErrors != nil {
-		logger.Warn("SyncFlowErrors: ", s.SyncFlowErrors)
+		logger.Warn("SyncFlowErrors", "errors", s.SyncFlowErrors)
 		s.SyncFlowErrors = nil
 	}
 
 	if s.NormalizeFlowErrors != nil {
-		logger.Warn("NormalizeFlowErrors: ", s.NormalizeFlowErrors)
+		logger.Warn("NormalizeFlowErrors", "errors", s.NormalizeFlowErrors)
 		s.NormalizeFlowErrors = nil
 	}
 }
@@ -558,7 +558,7 @@ func CDCFlowWorkflowWithConfig(
 
 			var childSyncFlowRes *model.SyncResponse
 			if err := f.Get(syncCtx, &childSyncFlowRes); err != nil {
-				w.logger.Error("failed to execute sync flow: ", err)
+				w.logger.Error("failed to execute sync flow", "error", err)
 				state.SyncFlowErrors = append(state.SyncFlowErrors, err.Error())
 				syncErr = true
 			} else if childSyncFlowRes != nil {