Factor out API helper classes from 'pubsub.Connection'. by tseaver · Pull Request #1736 · googleapis/google-cloud-python · GitHub

Uses #1700 as a base.

These API objects will represent logical groupings of the JSON api endpoints, and correspond one-for-one to the stubs exposed by the generated gRPC code. Further commits will move the endpoint-specific methods from the 'Connecttion' class into the relevant API classes, and adjust the callers. See: #1700 (comment)

…API'.

…erAPI'.

…yAPI'.

@dhermes Rebased after merging #1700 to master. PTAL

For non-test code, ISTM the only change after the cut-and-paste was self.api_request -> self.conn.api_request (and synonyms). Is that correct?

@tseaver LGTM save for my two three clarifications requested.

For non-test code, ISTM the only change after the cut-and-paste was self.api_request -> self.conn.api_request (and synonyms). Is that correct?

For the helper objects, yes. The callers now delegate to the methods of the helpers, rather than the connection.

Addresses: #1736 (comment)

@tseaver You jumped the gun a bit on the merge. I have an unanswered question:

Why couldn't those lines just be deleted?

regarding setting test connections to object(). Why do they need to be set at all?

141eab5 removed them.

I'm seeing

conn = client.connection = object()

on line 36 of gcloud/pubsub/test_client.py. Lines like that are ones I am curious about.

Instead of self.assertTrue(api._connection is conn) you could use self.assertIsNone(api._connection)

Co-authored-by: Anthonios Partheniou <partheniou@google.com>

* chore(python): Add Python 3.12 Source-Link: googleapis/synthtool@af16e6d Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:bacc3af03bff793a03add584537b36b5644342931ad989e3ba1171d3bd5399f5 * add trove classifier for python 3.12 * update kokoro configs * Add python 3.12 to noxfile.py * update georaphy sample requirements * update geography samples requirements * add testing constraint file for 3.12 * remove repr test --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: Anthonios Partheniou <partheniou@google.com> Co-authored-by: Linchin <lingqing.gan@gmail.com>

PR created by the Librarian CLI to initialize a release. Merging this PR will auto trigger a release. Librarian Version: v1.0.2-0.20251119154421-36c3e21ad3ac Language Image: us-central1-docker.pkg.dev/cloud-sdk-librarian-prod/images-prod/python-librarian-generator@sha256:8e2c32496077054105bd06c54a59d6a6694287bc053588e24debe6da6920ad91 <details><summary>google-cloud-storage: 3.9.0</summary> ## [3.9.0](googleapis/python-storage@v3.8.0...v3.9.0) (2026-02-02) ### Features * update generation for MRD (#1730) ([08bc7082](googleapis/python-storage@08bc7082)) * add get_object method for async grpc client (#1735) ([0e5ec29b](googleapis/python-storage@0e5ec29b)) * Add micro-benchmarks for reads comparing standard (regional) vs rapid (zonal) buckets. (#1697) ([1917649f](googleapis/python-storage@1917649f)) * Add support for opening via `write_handle` and fix `write_handle` type (#1715) ([2bc15fa5](googleapis/python-storage@2bc15fa5)) * add samples for appendable objects writes and reads ([2e1a1eb5](googleapis/python-storage@2e1a1eb5)) * add samples for appendable objects writes and reads (#1705) ([2e1a1eb5](googleapis/python-storage@2e1a1eb5)) * add context manager to mrd (#1724) ([5ac2808a](googleapis/python-storage@5ac2808a)) * Move Zonal Buckets features of `_experimental` (#1728) ([74c9ecc5](googleapis/python-storage@74c9ecc5)) * add default user agent for grpc (#1726) ([7b319469](googleapis/python-storage@7b319469)) * expose finalized_time in blob.py applicable for GET_OBJECT in ZB (#1719) ([8e21a7f](googleapis/python-storage@8e21a7fe)) * expose `DELETE_OBJECT` in `AsyncGrpcClient` (#1718) ([c8dd7a0b](googleapis/python-storage@c8dd7a0b)) * send `user_agent` to grpc channel (#1712) ([cdb2486b](googleapis/python-storage@cdb2486b)) * integrate writes strategy and appendable object writer (#1695) ([dbd162b3](googleapis/python-storage@dbd162b3)) * Add micro-benchmarks for writes comparing standard (regional) vs rapid (zonal) buckets. (#1707) ([dbe9d8b8](googleapis/python-storage@dbe9d8b8)) * add support for `generation=0` to avoid overwriting existing objects and add `is_stream_open` support (#1709) ([ea0f5bf8](googleapis/python-storage@ea0f5bf8)) * add support for `generation=0` to prevent overwriting existing objects ([ea0f5bf8](googleapis/python-storage@ea0f5bf8)) * add `is_stream_open` property to AsyncAppendableObjectWriter for stream status check ([ea0f5bf8](googleapis/python-storage@ea0f5bf8)) ### Bug Fixes * receive eof while closing reads stream (#1733) ([2ef63396](googleapis/python-storage@2ef63396)) * update write handle on every recv() (#1716) ([5d9fafe1](googleapis/python-storage@5d9fafe1)) * implement requests_done method to signal end of requests in async streams. Gracefully close streams. (#1700) ([6c160794](googleapis/python-storage@6c160794)) * implement requests_done method to signal end of requests in async streams. Gracefully close streams. ([6c160794](googleapis/python-storage@6c160794)) * instance grpc client once per process in benchmarks (#1725) ([721ea2dd](googleapis/python-storage@721ea2dd)) * Fix formatting in setup.py dependencies list (#1713) ([cc4831d7](googleapis/python-storage@cc4831d7)) * Change contructors of MRD and AAOW AsyncGrpcClient.grpc_client to AsyncGrpcClient (#1727) ([e730bf50](googleapis/python-storage@e730bf50)) </details>

- Added `grpc` extra (`"grpc": ["grpcio"]`) and updated `testing_extra_require` to use `*grpc_extra_require`. - Removed obsolete TODO comments for `grpcio`, `oauth2client`, and `urllib3` bounds. Fixes #1735 Fixes #1736 Fixes #1739

🤖 I have created a release *beep* *boop* --- <details><summary>google-apps-chat: 0.10.2</summary> ## [0.10.2](google-apps-chat-v0.10.1...google-apps-chat-v0.10.2) (2026-07-13) ### Features * update googleapis and regenerate ([#17678](#17678)) ([670917c](670917c)) </details> <details><summary>google-auth: 2.56.0</summary> ## [2.56.0](google-auth-v2.55.2...google-auth-v2.56.0) (2026-07-13) ### Features * **auth:** Implement python mtls helpers ([#17495](#17495)) ([e7baed1](e7baed1)) ### Bug Fixes * **google-auth:** add aiohttp bound for Python 3.14 ([#17654](#17654)) ([b2ec761](b2ec761)) * **google-auth:** add bounds for urllib3 and packaging dependencies ([#17647](#17647)) ([e9c6265](e9c6265)) * **google-auth:** add cryptography bound for Python 3.14 ([#17649](#17649)) ([e9ca4c4](e9ca4c4)) * **google-auth:** add gRPC extra and clean up obsolete TODOs ([#17644](#17644)) ([6da41e8](6da41e8)), closes [#1735](#1735) [#1736](#1736) [#1739](#1739) * **google-auth:** raise rsa extra lower bound to 4.0 ([#17652](#17652)) ([4087828](4087828)) </details> <details><summary>google-cloud-apigee-registry: 0.10.1</summary> ## [0.10.1](google-cloud-apigee-registry-v0.10.0...google-cloud-apigee-registry-v0.10.1) (2026-07-13) ### Features * update googleapis and regenerate ([#17678](#17678)) ([670917c](670917c)) </details> <details><summary>google-cloud-binary-authorization: 1.19.0</summary> ## [1.19.0](google-cloud-binary-authorization-v1.18.0...google-cloud-binary-authorization-v1.19.0) (2026-07-13) ### Features * update googleapis and regenerate ([#17678](#17678)) ([670917c](670917c)) </details> <details><summary>google-cloud-documentai-toolbox: 0.17.1</summary> ## [0.17.1](google-cloud-documentai-toolbox-v0.17.0...google-cloud-documentai-toolbox-v0.17.1) (2026-07-13) ### Bug Fixes * bump jinja2 from 3.1.0 to 3.1.6 in /packages/google-cloud-documentai-toolbox ([#17630](#17630)) ([4cfb931](4cfb931)) * bump pillow from 10.0.0 to 12.2.0 in /packages/google-cloud-documentai-toolbox ([#17631](#17631)) ([1838c35](1838c35)) </details> <details><summary>google-cloud-memorystore: 0.5.2</summary> ## [0.5.2](google-cloud-memorystore-v0.5.1...google-cloud-memorystore-v0.5.2) (2026-07-13) ### Features * update googleapis and regenerate ([#17678](#17678)) ([670917c](670917c)) </details> <details><summary>google-cloud-storage: 3.13.0</summary> ## [3.13.0](google-cloud-storage-v3.12.1...google-cloud-storage-v3.13.0) (2026-07-13) ### Features * **storage:** add option to disable checksums and improve robustness of full_object_checksum validation ([#17665](#17665)) ([a5a717d](a5a717d)) * **storage:** support full_object_checksum in AsyncAppendableObjectWriter ([#17658](#17658)) ([e08d5ca](e08d5ca)) </details> <details><summary>google-devicesandservices-health: 0.1.1</summary> ## [0.1.1](google-devicesandservices-health-v0.1.0...google-devicesandservices-health-v0.1.1) (2026-07-13) ### Features * update googleapis and regenerate ([#17678](#17678)) ([670917c](670917c)) </details> --- This PR was generated with [Release Please](https://github.com/googleapis/release-please). See [documentation](https://github.com/googleapis/release-please#release-please). Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com>

tseaver added the api: pubsub Issues related to the Pub/Sub API. label Apr 22, 2016

googlebot added the cla: yes This human has signed the Contributor License Agreement. label Apr 22, 2016

tseaver mentioned this pull request Apr 22, 2016

Add methods to connection mapping API requests #1700

Merged

tseaver added 6 commits April 22, 2016 12:14

Move 'list_topics' from 'Connection' to '_PublisherAPI'.

2c7c58b

Move 'list_subscriptions' from 'Connection' to '_SubscriberAPI'.

8edaec6

Move remaining publisher API methods from 'Connection' to '_Publisher…

2a54ffb

…API'.

Move remaining subscriber API methods from 'Connection' to '_Subscrib…

75bc6de

…erAPI'.

Move remaining IAM policy API methods from 'Connection' to '_IAMPolic…

080313c

…yAPI'.

tseaver assigned dhermes Apr 22, 2016

dhermes reviewed Apr 22, 2016
View reviewed changes

Comment thread gcloud/pubsub/test_connection.py

self.assertEqual(conn.build_api_url('/foo', api_base_url=base_url2),

URI)

def _verify_uri(self, uri, expected_path, **expected_qs):

This comment was marked as spam.

Sign in to view

This comment was marked as spam.

Sign in to view

tseaver added 2 commits April 22, 2016 13:08

'assertTrue(isinstance' -> 'assertIsInstance'.

77de8ed

Addresses: #1736 (comment)

Remove now-redundant mock connections.

141eab5

Addresses: #1736 (comment)

tseaver merged commit d97cffe into googleapis:master Apr 22, 2016

tseaver deleted the 851-1696-pubsub-api_helper_classes branch April 22, 2016 18:01

dhermes mentioned this pull request Apr 22, 2016

Upgrading version to 0.13.0. #1740

Merged

tseaver mentioned this pull request May 24, 2016

Factor API-related calls into service-specific helpers. #1820

Merged

theacodes unassigned dhermes Sep 28, 2018

parthea added a commit that referenced this pull request Nov 24, 2025

build: Update googleapis version (#1736 )

d1a4e5b

Co-authored-by: Anthonios Partheniou <partheniou@google.com>

parthea pushed a commit that referenced this pull request Apr 1, 2026

fix: Support str.replace re.compile with flags (#1736 )

c0533e3

ohmayr mentioned this pull request Jul 7, 2026

fix(google-auth): add extra for grpc #17644

Merged

release-please Bot mentioned this pull request Jul 7, 2026

chore: release main #17646

Merged

+                  def publisher_api(self):
+                      """Helper for publisher-related API calls."""
+                      if self._publisher_api is None:
+                          self._publisher_api = _PublisherAPI(self.connection)

Factor out API helper classes from 'pubsub.Connection'. by tseaver · Pull Request #1736 · googleapis/google-cloud-python · GitHub

Uh oh!

Factor out API helper classes from 'pubsub.Connection'. - #1736

Factor out API helper classes from 'pubsub.Connection'.#1736
tseaver merged 8 commits into
googleapis:masterfrom
tseaver:851-1696-pubsub-api_helper_classes

tseaver commented Apr 22, 2016 •
edited
Loading

Uh oh!

Uh oh!

tseaver commented Apr 22, 2016

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

dhermes commented Apr 22, 2016

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

dhermes commented Apr 22, 2016 •
edited
Loading

Uh oh!

Uh oh!

tseaver commented Apr 22, 2016

Uh oh!

dhermes commented Apr 22, 2016

Uh oh!

tseaver commented Apr 22, 2016

Uh oh!

dhermes commented Apr 22, 2016

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

                       self.assertEqual(conn.build_api_url('/foo', api_base_url=base_url2),
                                        URI)
-                  def _verify_uri(self, uri, expected_path, **expected_qs):

Factor out API helper classes from 'pubsub.Connection'. by tseaver · Pull Request #1736 · googleapis/google-cloud-python · GitHub

Uh oh!

Factor out API helper classes from 'pubsub.Connection'. - #1736

Factor out API helper classes from 'pubsub.Connection'.#1736tseaver merged 8 commits intogoogleapis:mastergoogleapis/google-cloud-python:masterfrom tseaver:851-1696-pubsub-api_helper_classesCopy head branch name to clipboard

Conversation

tseaver commented Apr 22, 2016 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

tseaver commented Apr 22, 2016

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

dhermes commented Apr 22, 2016

Uh oh!

This comment was marked as spam.

Uh oh!

This comment was marked as spam.

Uh oh!

dhermes commented Apr 22, 2016 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

tseaver commented Apr 22, 2016

Uh oh!

dhermes commented Apr 22, 2016

Uh oh!

tseaver commented Apr 22, 2016

Uh oh!

dhermes commented Apr 22, 2016

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Factor out API helper classes from 'pubsub.Connection'.#1736
tseaver merged 8 commits into
googleapis:masterfrom
tseaver:851-1696-pubsub-api_helper_classes

tseaver commented Apr 22, 2016 •
edited
Loading

dhermes commented Apr 22, 2016 •
edited
Loading