Skip to content

Conversation

acocuzzo
Copy link
Contributor

@acocuzzo acocuzzo commented Jul 26, 2022

Set "shutdown_mode" in the dispatcher. During this mode, set_exception(AcknowledgeError.OTHER) on dispatched callbacks.
When unary acks, modack, and nacks are returned check they are not already completed.

Fixes #747🦕

@product-auto-label product-auto-label bot added size: m Pull request size is medium. api: pubsub Issues related to the googleapis/python-pubsub API. labels Jul 26, 2022
@acocuzzo acocuzzo changed the title Complete futures on shutdown Fix: Complete futures on shutdown Jul 26, 2022
@acocuzzo acocuzzo mentioned this pull request Jul 26, 2022
4 tasks
@mukund-ananthu mukund-ananthu added the do not merge Indicates a pull request not ready for merge, due to either quality or timing. label Feb 27, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
api: pubsub Issues related to the googleapis/python-pubsub API. do not merge Indicates a pull request not ready for merge, due to either quality or timing. size: m Pull request size is medium.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Complete futures on irregular stream shutdown
3 participants