Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit eb088d0

Browse files
committed
Add condition to try query external tables if none found in redshift
1 parent 82beb97 commit eb088d0

File tree

1 file changed

+2
-0
lines changed
  • data_diff/sqeleton/databases

1 file changed

+2
-0
lines changed

data_diff/sqeleton/databases/base.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -339,6 +339,8 @@ def select_table_schema(self, path: DbPath) -> str:
339339

340340
def query_table_schema(self, path: DbPath) -> Dict[str, tuple]:
341341
rows = self.query(self.select_table_schema(path), list)
342+
if not rows and self.name == 'Redshift':
343+
rows = self.query(self.select_external_table_schema(path), list)
342344
if not rows:
343345
raise RuntimeError(f"{self.name}: Table '{'.'.join(path)}' does not exist, or has no columns")
344346

0 commit comments

Comments
 (0)