You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This results in race conditions where the callback associated with the future is invoked before the client enters paused state. Which causes issues if the callback attempts to do a resume_publish() before the client is in the paused state.
The text was updated successfully, but these errors were encountered:
For non-retriable errors returned from the backend, the client library currently sets future.set_exception() for all outstanding futures:
python-pubsub/google/cloud/pubsub_v1/publisher/_batch/thread.py
Lines 285 to 286 in 8c7e2a9
before it tries to change its state to paused by calling the _batch_done_callback():
python-pubsub/google/cloud/pubsub_v1/publisher/_batch/thread.py
Lines 289 to 291 in 8c7e2a9
This results in race conditions where the callback associated with the future is invoked before the client enters paused state. Which causes issues if the callback attempts to do a resume_publish() before the client is in the paused state.
The text was updated successfully, but these errors were encountered: