Skip to content

Commit e325fbb

Browse files
milkshakeiiiHenry J Solberg
and
Henry J Solberg
authored
feat: send BigQuery cancel request when canceling bigframes process (#103)
Co-authored-by: Henry J Solberg <[email protected]>
1 parent 3b51a36 commit e325fbb

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

bigframes/formatting_helpers.py

+10
Original file line numberDiff line numberDiff line change
@@ -153,6 +153,11 @@ def wait_for_query_job(
153153
except api_core_exceptions.GoogleAPICallError as exc:
154154
add_feedback_link(exc)
155155
raise
156+
except KeyboardInterrupt:
157+
query_job.cancel()
158+
print(f"Requested cancelation for {query_job.job_type} {query_job.job_id}...")
159+
# begin the cancel request before immediately rethrowing
160+
raise
156161

157162

158163
def wait_for_job(job: GenericJob, progress_bar: Optional[str] = None):
@@ -190,6 +195,11 @@ def wait_for_job(job: GenericJob, progress_bar: Optional[str] = None):
190195
except api_core_exceptions.GoogleAPICallError as exc:
191196
add_feedback_link(exc)
192197
raise
198+
except KeyboardInterrupt:
199+
job.cancel()
200+
print(f"Requested cancelation for {job.job_type} {job.job_id}...")
201+
# begin the cancel request before immediately rethrowing
202+
raise
193203

194204

195205
def get_job_url(query_job: GenericJob):

0 commit comments

Comments
 (0)