diff --git a/dlt/destinations/dataset/relation.py b/dlt/destinations/dataset/relation.py index 0ae6eae536..2cdb7640df 100644 --- a/dlt/destinations/dataset/relation.py +++ b/dlt/destinations/dataset/relation.py @@ -133,7 +133,7 @@ def query(self) -> Any: if self._selected_columns: selector = ",".join( [ - self.sql_client.escape_column_name(self.schema.naming.normalize_path(c)) + self.sql_client.escape_column_name(self.schema.naming.normalize_tables_path(c)) for c in self._selected_columns ] )