René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Publisher Client does not enter paused state before future.set_exception","articleBody":"For non-retriable errors returned from the backend, the client library currently sets future.set_exception() for all outstanding futures:\r\n\r\nhttps://github.com/googleapis/python-pubsub/blob/8c7e2a9e1b158e2b75dec8c5d78be17ce2dd449b/google/cloud/pubsub_v1/publisher/_batch/thread.py#L285-L286\r\n\r\n\r\nbefore it tries to change its state to paused by calling the _batch_done_callback():\r\nhttps://github.com/googleapis/python-pubsub/blob/8c7e2a9e1b158e2b75dec8c5d78be17ce2dd449b/google/cloud/pubsub_v1/publisher/_batch/thread.py#L289-L291\r\n\r\nThis 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.","author":{"url":"https://github.com/mukund-ananthu","@type":"Person","name":"mukund-ananthu"},"datePublished":"2024-04-14T23:45:46.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/1144/python-pubsub/issues/1144"}