forgot the query

Author: dlawin

data_diff/databases/redshift.py

@@ -146,6 +146,15 @@ def select_svv_columns_schema(self, path: DbPath) -> Dict[str, tuple]:
             + db_clause
         )
 
+    def query_svv_columns(self, path: DbPath) -> Dict[str, tuple]:
+        rows = self.query(self.select_svv_columns_schema(path), list)
+        if not rows:
+            raise RuntimeError(f"{self.name}: Table '{'.'.join(path)}' does not exist, or has no columns")
+
+        d = {r[0]: r for r in rows}
+        assert len(d) == len(rows)
+        return d
+
     # when using a non-information_schema source, strip (N) from type(N) etc. to match
     # typical information_schema output
     def _normalize_schema_info(self, rows) -> Dict[str, tuple]:
@@ -177,7 +186,7 @@ def query_table_schema(self, path: DbPath) -> Dict[str, tuple]:
                 try:
                     return self.query_pg_get_cols(path)
                 except Exception:
-                    return self.select_svv_columns_schema(path)
+                    return self.query_svv_columns(path)
 
     def _normalize_table_path(self, path: DbPath) -> DbPath:
         if len(path) == 1: