Update flow/connectors/postgres/cdc.go

Co-authored-by: Philip Dubé <[email protected]>
PeerDB-io · Jun 15, 2024 · 8ee8c2d · 8ee8c2d
1 parent a51daba
commit 8ee8c2d
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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
 		}