Currently we always reconnect on "RST_STREAM" errors:
|
except _STREAM_RESUMPTION_EXCEPTIONS: |
|
# Transient error, so reconnect to the stream. |
|
pass |
|
|
|
self._reconnect() |
This may cause some infinite loops, especially if we add other errors such as UNAUTHENTICATED to the stream resumption logic to support customer issue 191460918. Pub/Sub and Firestore have already solved this with the shared BiDi (bi-directional) classes.
Resources:
Reactions are currently unavailable
Currently we always reconnect on "RST_STREAM" errors:
python-bigquery-storage/google/cloud/bigquery_storage_v1/reader.py
Lines 147 to 151 in 7e4224e
This may cause some infinite loops, especially if we add other errors such as UNAUTHENTICATED to the stream resumption logic to support customer issue 191460918. Pub/Sub and Firestore have already solved this with the shared BiDi (bi-directional) classes.
Resources: