Skip to content

Commit e4ea4c8

Browse files
authored
fix: BigQueryEngineAdapter.get_table_schema() mypy error (#5153)
1 parent a2e4bbf commit e4ea4c8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

sqlmesh/core/engine_adapter/bigquery.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -296,7 +296,9 @@ def get_bq_schema(self, table_name: TableName) -> t.List[bigquery.SchemaField]:
296296
table = exp.to_table(table_name)
297297
if len(table.parts) == 3 and "." in table.name:
298298
self.execute(exp.select("*").from_(table).limit(0))
299-
return self._query_job._query_results.schema
299+
query_job = self._query_job
300+
assert query_job is not None
301+
return query_job._query_results.schema
300302
return self._get_table(table).schema
301303

302304
def columns(

0 commit comments

Comments
 (0)