Skip to content

Commit

Permalink
Fix get_table_column_names_and_types for postgres source
Browse files Browse the repository at this point in the history
Signed-off-by: Dimitris Stafylarakis <xanias@gmail.com>
  • Loading branch information
xaniasd authored and felixwang9817 committed Jan 15, 2023
1 parent 38d5534 commit d90e402
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ def get_table_column_names_and_types(
) -> Iterable[Tuple[str, str]]:
with _get_conn(config.offline_store) as conn, conn.cursor() as cur:
cur.execute(
f"SELECT * FROM ({self.get_table_query_string()}) AS sub LIMIT 0"
f"SELECT * FROM {self.get_table_query_string()} AS sub LIMIT 0"
)
return (
(c.name, pg_type_code_to_pg_type(c.type_code)) for c in cur.description
Expand Down

0 comments on commit d90e402

Please sign in to comment.