Skip to content
This repository was archived by the owner on Mar 9, 2026. It is now read-only.

Commit d7e4ba7

Browse files
1 parent cd332d3 commit d7e4ba7

160 files changed

Lines changed: 45 additions & 77051 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

google/pubsub_v1/services/publisher/async_client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
from google.api_core import retry_async as retries
3838
from google.auth import credentials as ga_credentials # type: ignore
3939
from google.oauth2 import service_account # type: ignore
40+
import google.protobuf
4041

4142

4243
try:
@@ -1662,5 +1663,8 @@ async def __aexit__(self, exc_type, exc, tb):
16621663
client_library_version=package_version.__version__
16631664
)
16641665

1666+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
1667+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
1668+
16651669

16661670
__all__ = ("PublisherAsyncClient",)

google/pubsub_v1/services/publisher/client.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@
4747
from google.auth.transport.grpc import SslCredentials # type: ignore
4848
from google.auth.exceptions import MutualTLSChannelError # type: ignore
4949
from google.oauth2 import service_account # type: ignore
50+
import google.protobuf
5051

5152
try:
5253
OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault, None]
@@ -2129,5 +2130,7 @@ def test_iam_permissions(
21292130
client_library_version=package_version.__version__
21302131
)
21312132

2133+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
2134+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
21322135

21332136
__all__ = ("PublisherClient",)

google/pubsub_v1/services/publisher/transports/base.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
from google.api_core import retry as retries
2626
from google.auth import credentials as ga_credentials # type: ignore
2727
from google.oauth2 import service_account # type: ignore
28+
import google.protobuf
2829

2930
from google.iam.v1 import iam_policy_pb2 # type: ignore
3031
from google.iam.v1 import policy_pb2 # type: ignore
@@ -35,6 +36,9 @@
3536
client_library_version=package_version.__version__
3637
)
3738

39+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
40+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
41+
3842

3943
class PublisherTransport(abc.ABC):
4044
"""Abstract transport class for Publisher."""

google/pubsub_v1/services/publisher/transports/rest.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
from google.api_core import rest_helpers
2424
from google.api_core import rest_streaming
2525
from google.api_core import gapic_v1
26+
import google.protobuf
2627

2728
from google.protobuf import json_format
2829
from google.iam.v1 import iam_policy_pb2 # type: ignore
@@ -61,6 +62,9 @@
6162
rest_version=f"requests@{requests_version}",
6263
)
6364

65+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
66+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
67+
6468

6569
class PublisherRestInterceptor:
6670
"""Interceptor for Publisher.

google/pubsub_v1/services/schema_service/async_client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
from google.api_core import retry_async as retries
3838
from google.auth import credentials as ga_credentials # type: ignore
3939
from google.oauth2 import service_account # type: ignore
40+
import google.protobuf
4041

4142

4243
try:
@@ -1775,5 +1776,8 @@ async def __aexit__(self, exc_type, exc, tb):
17751776
client_library_version=package_version.__version__
17761777
)
17771778

1779+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
1780+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
1781+
17781782

17791783
__all__ = ("SchemaServiceAsyncClient",)

google/pubsub_v1/services/schema_service/client.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@
4646
from google.auth.transport.grpc import SslCredentials # type: ignore
4747
from google.auth.exceptions import MutualTLSChannelError # type: ignore
4848
from google.oauth2 import service_account # type: ignore
49+
import google.protobuf
4950

5051
try:
5152
OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault, None]
@@ -2190,5 +2191,7 @@ def test_iam_permissions(
21902191
client_library_version=package_version.__version__
21912192
)
21922193

2194+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
2195+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
21932196

21942197
__all__ = ("SchemaServiceClient",)

google/pubsub_v1/services/schema_service/transports/base.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
from google.api_core import retry as retries
2626
from google.auth import credentials as ga_credentials # type: ignore
2727
from google.oauth2 import service_account # type: ignore
28+
import google.protobuf
2829

2930
from google.iam.v1 import iam_policy_pb2 # type: ignore
3031
from google.iam.v1 import policy_pb2 # type: ignore
@@ -36,6 +37,9 @@
3637
client_library_version=package_version.__version__
3738
)
3839

40+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
41+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
42+
3943

4044
class SchemaServiceTransport(abc.ABC):
4145
"""Abstract transport class for SchemaService."""

google/pubsub_v1/services/schema_service/transports/rest.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
from google.api_core import rest_helpers
2424
from google.api_core import rest_streaming
2525
from google.api_core import gapic_v1
26+
import google.protobuf
2627

2728
from google.protobuf import json_format
2829
from google.iam.v1 import iam_policy_pb2 # type: ignore
@@ -62,6 +63,9 @@
6263
rest_version=f"requests@{requests_version}",
6364
)
6465

66+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
67+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
68+
6569

6670
class SchemaServiceRestInterceptor:
6771
"""Interceptor for SchemaService.

google/pubsub_v1/services/subscriber/async_client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
from google.api_core import retry_async as retries
4242
from google.auth import credentials as ga_credentials # type: ignore
4343
from google.oauth2 import service_account # type: ignore
44+
import google.protobuf
4445

4546

4647
try:
@@ -2635,5 +2636,8 @@ async def __aexit__(self, exc_type, exc, tb):
26352636
client_library_version=package_version.__version__
26362637
)
26372638

2639+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
2640+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
2641+
26382642

26392643
__all__ = ("SubscriberAsyncClient",)

google/pubsub_v1/services/subscriber/client.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@
4949
from google.auth.transport.grpc import SslCredentials # type: ignore
5050
from google.auth.exceptions import MutualTLSChannelError # type: ignore
5151
from google.oauth2 import service_account # type: ignore
52+
import google.protobuf
5253

5354
try:
5455
OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault, None]
@@ -3087,5 +3088,7 @@ def test_iam_permissions(
30873088
client_library_version=package_version.__version__
30883089
)
30893090

3091+
if hasattr(DEFAULT_CLIENT_INFO, "protobuf_runtime_version"): # pragma: NO COVER
3092+
DEFAULT_CLIENT_INFO.protobuf_runtime_version = google.protobuf.__version__
30903093

30913094
__all__ = ("SubscriberClient",)

0 commit comments

Comments
 (0)