From 2882e0a377af231cb0f21ad6e5c879a43da781ef Mon Sep 17 00:00:00 2001 From: David Dai Date: Wed, 13 Aug 2025 17:11:36 -0700 Subject: [PATCH] fix: BigQueryEngineAdapter.get_table_schema() mypy error --- sqlmesh/core/engine_adapter/bigquery.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sqlmesh/core/engine_adapter/bigquery.py b/sqlmesh/core/engine_adapter/bigquery.py index d3280db137..2de3f18c99 100644 --- a/sqlmesh/core/engine_adapter/bigquery.py +++ b/sqlmesh/core/engine_adapter/bigquery.py @@ -296,7 +296,9 @@ def get_bq_schema(self, table_name: TableName) -> t.List[bigquery.SchemaField]: table = exp.to_table(table_name) if len(table.parts) == 3 and "." in table.name: self.execute(exp.select("*").from_(table).limit(0)) - return self._query_job._query_results.schema + query_job = self._query_job + assert query_job is not None + return query_job._query_results.schema return self._get_table(table).schema def columns(