From c0d46b6d58e9a63abd2d2e1cc403018ea941ec6d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Mon, 12 Feb 2024 18:17:02 +0000 Subject: [PATCH] cdc_flow: cleanup error logging --- flow/workflows/cdc_flow.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go index cee5fde13f..09af1b0c45 100644 --- 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 {