We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7a20897 commit c125ca3Copy full SHA for c125ca3
1 file changed
sqlmesh/core/engine_adapter/bigquery.py
@@ -189,8 +189,17 @@ def query_factory() -> Query:
189
def close(self) -> t.Any:
190
# Cancel all pending query jobs to avoid them becoming orphan, e.g., due to interrupts
191
for query_job in self._query_jobs:
192
- if not self._db_call(query_job.done):
193
- self._db_call(query_job.cancel)
+ try:
+ if not self._db_call(query_job.done):
194
+ self._db_call(query_job.cancel)
195
+ except Exception as ex:
196
+ logger.debug(
197
+ "Failed to cancel BigQuery job: https://console.cloud.google.com/bigquery?project=%s&j=bq:%s:%s. %s",
198
+ self._query_job.project,
199
+ self._query_job.location,
200
+ self._query_job.job_id,
201
+ str(ex),
202
+ )
203
204
self._query_jobs.clear()
205
return super().close()
0 commit comments