From 9a3e1eefe706f200e61c5f721976a25d02b08179 Mon Sep 17 00:00:00 2001
From: Kevin K Biju <52661649+heavycrystal@users.noreply.github.com>
Date: Sat, 21 Oct 2023 20:24:01 +0100
Subject: [PATCH] reintroduce not erroring out when no primary keys &&
 isFullReplica (#550)

---
 flow/connectors/postgres/postgres.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
index a4df6246d3..c550ae1445 100644
--- a/flow/connectors/postgres/postgres.go
+++ b/flow/connectors/postgres/postgres.go
@@ -602,7 +602,9 @@ func (c *PostgresConnector) getTableSchemaForTable(
 
 	pKeyCols, err := c.getPrimaryKeyColumns(schemaTable)
 	if err != nil {
-		return nil, fmt.Errorf("error getting primary key column for table %s: %w", schemaTable, err)
+		if !isFullReplica {
+			return nil, fmt.Errorf("error getting primary key column for table %s: %w", schemaTable, err)
+		}
 	}
 
 	res := &protos.TableSchema{