From 8ee8c2deb3fcd87b34a5aa60237d863a31eaa459 Mon Sep 17 00:00:00 2001 From: Kevin Biju <52661649+heavycrystal@users.noreply.github.com> Date: Sat, 15 Jun 2024 11:50:08 +0530 Subject: [PATCH] Update flow/connectors/postgres/cdc.go MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Philip Dubé --- flow/connectors/postgres/cdc.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index 5714288c75..7f312e2012 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -346,8 +346,7 @@ func PullCdcRecords[Items model.Items]( if err != nil { return err } - err = records.AddRecord(ctx, rec) - if err != nil { + if err := records.AddRecord(ctx, rec); err != nil { return err }