Skip to content

Commit f93651b

Browse files
sfc-gh-kteradasfc-gh-aling
authored andcommitted
Update snowdialect.py
Start addressing native sqlalchemy unit test failures
1 parent a7f76b0 commit f93651b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/snowflake/sqlalchemy/snowdialect.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -323,13 +323,13 @@ def _get_table_primary_keys(self, connection, schema, table_name, **kw):
323323
fully_qualified_path = self._denormalize_quote_join(schema, table_name)
324324
result = connection.execute(
325325
text(
326-
f"SHOW /* sqlalchemy:_get_table_primary_keys */PRIMARY KEYS IN TABLE {fully_qualified_path}"
326+
f"SHOW /* sqlalchemy:_get_table_primary_keys */ PRIMARY KEYS IN TABLE {fully_qualified_path}"
327327
)
328328
)
329329
else:
330330
result = connection.execute(
331331
text(
332-
f"SHOW /* sqlalchemy:_get_table_primary_keys */PRIMARY KEYS IN TABLE {schema}.{table_name}"
332+
f"SHOW /* sqlalchemy:_get_table_primary_keys */ PRIMARY KEYS IN TABLE {schema}.{table_name}"
333333
)
334334
)
335335
ans = {}
@@ -460,7 +460,7 @@ def get_unique_constraints(self, connection, table_name, schema, **kw):
460460
return self._get_table_unique_constraints(
461461
connection,
462462
self.denormalize_name(full_schema_name),
463-
self.normalize_name(table_name),
463+
self.denormalize_name(table_name),
464464
**kw,
465465
).get(table_name, [])
466466
else:
@@ -616,7 +616,7 @@ def get_foreign_keys(self, connection, table_name, schema=None, **kw):
616616
foreign_key_map = self._get_table_foreign_keys(
617617
connection,
618618
self.denormalize_name(full_schema_name),
619-
self.normalize_name(table_name),
619+
self.denormalize_name(table_name),
620620
**kw,
621621
)
622622
else:

0 commit comments

Comments
 (0)