Skip to content

Commit

Permalink
Use full_table_name to get table object
Browse files Browse the repository at this point in the history
  • Loading branch information
edgarrmondragon committed Oct 21, 2024
1 parent 06f54d0 commit 900cd57
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion singer_sdk/connectors/sql.py
Original file line number Diff line number Diff line change
Expand Up @@ -1002,7 +1002,7 @@ def prepare_primary_key(
_, schema_name, table_name = self.parse_full_table_name(full_table_name)
meta = sa.MetaData(schema=schema_name)
meta.reflect(bind=self._engine, only=[table_name])
table = meta.tables[f"{schema_name}.{table_name}"]
table = meta.tables[full_table_name]
current_pk_cols = [col.name for col in table.primary_key.columns]

# Nothing to do
Expand Down

0 comments on commit 900cd57

Please sign in to comment.