diff --git a/sqlmesh/core/engine_adapter/bigquery.py b/sqlmesh/core/engine_adapter/bigquery.py index d7ce9d56b8..6c2562af5a 100644 --- a/sqlmesh/core/engine_adapter/bigquery.py +++ b/sqlmesh/core/engine_adapter/bigquery.py @@ -265,7 +265,7 @@ def create_mapping_schema( table = exp.to_table(table_name) if len(table.parts) == 3 and "." in table.name: # The client's `get_table` method can't handle paths with >3 identifiers - self.execute(exp.select("*").from_(table).limit(1)) + self.execute(exp.select("*").from_(table).limit(0)) query_results = self._query_job._query_results columns = create_mapping_schema(query_results.schema) else: