Skip to content

Commit 55a568d

Browse files
committed
Clear query_jobs set on close()
1 parent fe854dc commit 55a568d

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

sqlmesh/core/engine_adapter/bigquery.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -192,6 +192,7 @@ def close(self) -> t.Any:
192192
if not self._db_call(query_job.done):
193193
self._db_call(query_job.cancel)
194194

195+
self._query_jobs.clear()
195196
return super().close()
196197

197198
def _begin_session(self, properties: SessionProperties) -> None:

0 commit comments

Comments
 (0)