Skip to content

Commit 1890eee

Browse files
Update packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/writer.py
Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
1 parent 090dc4b commit 1890eee

File tree

1 file changed

+1
-1
lines changed
  • packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1

1 file changed

+1
-1
lines changed

packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/writer.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ def _renew_connection(self, reason: Optional[Exception] = None) -> None:
211211
# critical section, this step is not guaranteed to be atomic.
212212
_closed_connection._shutdown(reason=reason)
213213

214-
def _on_rpc_done(self, reason: Optional[BaseException | Exception] = None) -> None:
214+
def _on_rpc_done(self, reason: Optional[BaseException] = None) -> None:
215215
"""Callback passecd to _Connection. It's called when the RPC connection
216216
is closed without recovery. Spins up a new thread to call the helper
217217
function `_renew_connection()`, which creates a new connection and

0 commit comments

Comments
 (0)