reintroduce not erroring out when no primary keys && isFullReplica (#550

)
PeerDB-io · Oct 21, 2023 · 9a3e1ee · 9a3e1ee
1 parent c9b6afe
commit 9a3e1ee
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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{