Skip to content

Add SubscriberClient.close() to examples #2959

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Closed
wants to merge 2 commits into from
Closed

Add SubscriberClient.close() to examples #2959

wants to merge 2 commits into from

Conversation

pradn
Copy link
Contributor

@pradn pradn commented Feb 21, 2020

No description provided.

@pradn pradn requested review from anguillanneuf, hongalex and a team as code owners February 21, 2020 21:42
@googlebot googlebot added the cla: yes This human has signed the Contributor License Agreement. label Feb 21, 2020
anguillanneuf
anguillanneuf approved these changes Feb 22, 2020
View reviewed changes
Copy link
Member

@anguillanneuf anguillanneuf left a comment •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thank you for the updates! I have always wondered why we have this method but never seem to use it anywhere. LGTM once all tests pass.

@pradn
Copy link
Contributor Author

pradn commented Feb 22, 2020

The close() method was only recently added. Perhaps you're thinking of something else?

googleapis/python-pubsub@b58d0d8

@anguillanneuf
Copy link
Member

anguillanneuf commented Feb 22, 2020 •
edited
Loading

@pradn Is it not this one here?

https://googleapis.dev/python/pubsub/latest/subscriber/api/client.html#google.cloud.pubsub_v1.subscriber.client.Client.close

Ah, I see. I was thinking of this one:

https://github.com/googleapis/python-pubsub/blob/380cb384217a0a032ded3d7586804c2373af5015/google/cloud/pubsub_v1/subscriber/_protocol/streaming_pull_manager.py#L478-L490

I think something is wrong with the code because tests are stuck. I can take a close look next week.

anguillanneuf
anguillanneuf requested changes Feb 24, 2020
View reviewed changes
Copy link
Member

@anguillanneuf anguillanneuf left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please fix the tests.

anguillanneuf
anguillanneuf reviewed Feb 24, 2020
View reviewed changes
pubsub/cloud-client/quickstart/sub.py
except: # noqa
streaming_pull_future.cancel()
# Wrap subscriber in a 'with' block to automatically call close() when done.
with subscriber:
Copy link
Member

@anguillanneuf anguillanneuf Feb 24, 2020 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This should be with client.

anguillanneuf
anguillanneuf requested changes Feb 25, 2020
View reviewed changes
Copy link
Member

@anguillanneuf anguillanneuf left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The library version looks outdated in requirements.txt.

@anguillanneuf
Copy link
Member

@pradn This branch has conflicts that must be resolved. I'm closing your PR and will work on a new one.

@anguillanneuf anguillanneuf mentioned this pull request Mar 19, 2020
Merged
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@anguillanneuf anguillanneuf anguillanneuf requested changes

@hongalex hongalex Awaiting requested review from hongalex

+1 more reviewer

@busunkim96 busunkim96 busunkim96 approved these changes

Reviewers whose approvals may not affect merge requirements
Assignees

@gguuss gguuss

Labels
cla: yes This human has signed the Contributor License Agreement.
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
5 participants
@pradn @anguillanneuf @busunkim96 @gguuss @googlebot