diff --git a/ingestion/src/metadata/ingestion/source/database/trino/metadata.py b/ingestion/src/metadata/ingestion/source/database/trino/metadata.py index e0fff3acd1e..bd2039cae1e 100644 --- a/ingestion/src/metadata/ingestion/source/database/trino/metadata.py +++ b/ingestion/src/metadata/ingestion/source/database/trino/metadata.py @@ -103,7 +103,7 @@ def _get_columns( ) -> List[Dict[str, Any]]: # pylint: disable=protected-access schema = schema or self._get_default_schema_name(connection) - query = f"SHOW COLUMNS FROM {schema}.{table_name}" + query = f'SHOW COLUMNS FROM {schema}."{table_name}"' res = connection.execute(sql.text(query), schema=schema, table=table_name) columns = []