diff --git a/parsons/databases/redshift/rs_table_utilities.py b/parsons/databases/redshift/rs_table_utilities.py index ae0c8a5c71..50457e3166 100644 --- a/parsons/databases/redshift/rs_table_utilities.py +++ b/parsons/databases/redshift/rs_table_utilities.py @@ -428,6 +428,17 @@ def get_columns_list(self, schema, table_name): `Returns:` A list of column names. """ + schema = ( + f'"{schema}"' + if not (schema.startswith('"') and schema.endswith('"')) + else schema + ) + + table_name = ( + f'"{table_name}"' + if not (table_name.startswith('"') and table_name.endswith('"')) + else table_name + ) first_row = self.query(f"select * from {schema}.{table_name} limit 1")