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

Commit 1f30ef7

Browse files
yoshi-automationyoshi-automation
authored
chore: use gapic-generator-python 0.50.3 (#404)
This PR was generated using Autosynth. 🌈 Synth log will be available here: https://source.cloud.google.com/results/invocations/1cb8ad84-81d7-41ae-80cc-f275d38cb08c/targets - [ ] To automatically regenerate this PR, check this box. (May take up to 24 hours.) PiperOrigin-RevId: 383459959 Source-Link: googleapis/googleapis@fe3cc5e PiperOrigin-RevId: 382318016 Source-Link: googleapis/googleapis@e9b2b61 PiperOrigin-RevId: 382142900 Source-Link: googleapis/googleapis@513440f PiperOrigin-RevId: 381898347 Source-Link: googleapis/googleapis@2bf1e2a PiperOrigin-RevId: 380641501 Source-Link: googleapis/googleapis@076f7e9 PiperOrigin-RevId: 373649163 Source-Link: googleapis/googleapis@7e1b14e PiperOrigin-RevId: 373400747 Source-Link: googleapis/googleapis@162641c PiperOrigin-RevId: 372197450 Source-Link: googleapis/googleapis@83a7e1c PiperOrigin-RevId: 371362703 Source-Link: googleapis/googleapis@5a04154 PiperOrigin-RevId: 370989216 Source-Link: googleapis/googleapis@4e82555 PiperOrigin-RevId: 370926454 Source-Link: googleapis/googleapis@382ed8d PiperOrigin-RevId: 370525906 Source-Link: googleapis/googleapis@60e129d This PR includes the following features/fixes: fix: add async client to %name_%version/init.py chore: add autogenerated snippets chore: remove auth, policy, and options from the reserved names list feat: support self-signed JWT flow for service accounts chore: enable GAPIC metadata generation chore: sort subpackages in %namespace/%name/init.py feat: add always_use_jwt_access fix: disable always_use_jwt_access feat: add subscription properties to streaming pull response feat: add method signature for Subscriber.Pull without the deprecated return_immediately field. fix(deps): require google-api-core >= 1.26.0 fix(deps): add packaging requirement
1 parent 5c5fc9f commit 1f30ef7

45 files changed

Lines changed: 2815 additions & 2418 deletions

Some content is hidden

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

‎.coveragerc‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22
branch = True
33

44
[report]
5-
fail_under = 100
65
show_missing = True
76
omit =
87
google/cloud/__init__.py

‎google/cloud/pubsub_v1/proto/pubsub.proto‎

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// Copyright 2020 Google LLC
1+
// Copyright 2021 Google LLC
22
//
33
// Licensed under the Apache License, Version 2.0 (the "License");
44
// you may not use this file except in compliance with the License.
@@ -505,6 +505,7 @@ service Subscriber {
505505
};
506506
option (google.api.method_signature) =
507507
"subscription,return_immediately,max_messages";
508+
option (google.api.method_signature) = "subscription,max_messages";
508509
}
509510

510511
// Establishes a stream with the server, which sends messages down to the
@@ -1142,8 +1143,17 @@ message StreamingPullRequest {
11421143
// Response for the `StreamingPull` method. This response is used to stream
11431144
// messages from the server to the client.
11441145
message StreamingPullResponse {
1146+
// Subscription properties sent as part of the response.
1147+
message SubscriptionProperties {
1148+
// True iff message ordering is enabled for this subscription.
1149+
bool message_ordering_enabled = 2;
1150+
}
1151+
11451152
// Received Pub/Sub messages. This will not be empty.
11461153
repeated ReceivedMessage received_messages = 1;
1154+
1155+
// Properties associated with this subscription.
1156+
SubscriptionProperties subscription_properties = 4;
11471157
}
11481158

11491159
// Request for the `CreateSnapshot` method.

‎google/pubsub/__init__.py‎

Lines changed: 24 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
# -*- coding: utf-8 -*-
2-
32
# Copyright 2020 Google LLC
43
#
54
# Licensed under the Apache License, Version 2.0 (the "License");
@@ -15,14 +14,15 @@
1514
# limitations under the License.
1615
#
1716

18-
from google.pubsub_v1.services.publisher.async_client import PublisherAsyncClient
1917
from google.pubsub_v1.services.publisher.client import PublisherClient
18+
from google.pubsub_v1.services.publisher.async_client import PublisherAsyncClient
19+
from google.pubsub_v1.services.schema_service.client import SchemaServiceClient
2020
from google.pubsub_v1.services.schema_service.async_client import (
2121
SchemaServiceAsyncClient,
2222
)
23-
from google.pubsub_v1.services.schema_service.client import SchemaServiceClient
24-
from google.pubsub_v1.services.subscriber.async_client import SubscriberAsyncClient
2523
from google.pubsub_v1.services.subscriber.client import SubscriberClient
24+
from google.pubsub_v1.services.subscriber.async_client import SubscriberAsyncClient
25+
2626
from google.pubsub_v1.types.pubsub import AcknowledgeRequest
2727
from google.pubsub_v1.types.pubsub import CreateSnapshotRequest
2828
from google.pubsub_v1.types.pubsub import DeadLetterPolicy
@@ -41,10 +41,10 @@
4141
from google.pubsub_v1.types.pubsub import ListSubscriptionsResponse
4242
from google.pubsub_v1.types.pubsub import ListTopicSnapshotsRequest
4343
from google.pubsub_v1.types.pubsub import ListTopicSnapshotsResponse
44-
from google.pubsub_v1.types.pubsub import ListTopicSubscriptionsRequest
45-
from google.pubsub_v1.types.pubsub import ListTopicSubscriptionsResponse
4644
from google.pubsub_v1.types.pubsub import ListTopicsRequest
4745
from google.pubsub_v1.types.pubsub import ListTopicsResponse
46+
from google.pubsub_v1.types.pubsub import ListTopicSubscriptionsRequest
47+
from google.pubsub_v1.types.pubsub import ListTopicSubscriptionsResponse
4848
from google.pubsub_v1.types.pubsub import MessageStoragePolicy
4949
from google.pubsub_v1.types.pubsub import ModifyAckDeadlineRequest
5050
from google.pubsub_v1.types.pubsub import ModifyPushConfigRequest
@@ -69,78 +69,78 @@
6969
from google.pubsub_v1.types.pubsub import UpdateTopicRequest
7070
from google.pubsub_v1.types.schema import CreateSchemaRequest
7171
from google.pubsub_v1.types.schema import DeleteSchemaRequest
72-
from google.pubsub_v1.types.schema import Encoding
7372
from google.pubsub_v1.types.schema import GetSchemaRequest
7473
from google.pubsub_v1.types.schema import ListSchemasRequest
7574
from google.pubsub_v1.types.schema import ListSchemasResponse
7675
from google.pubsub_v1.types.schema import Schema
77-
from google.pubsub_v1.types.schema import SchemaView
7876
from google.pubsub_v1.types.schema import ValidateMessageRequest
7977
from google.pubsub_v1.types.schema import ValidateMessageResponse
8078
from google.pubsub_v1.types.schema import ValidateSchemaRequest
8179
from google.pubsub_v1.types.schema import ValidateSchemaResponse
80+
from google.pubsub_v1.types.schema import Encoding
81+
from google.pubsub_v1.types.schema import SchemaView
8282

8383
__all__ = (
84+
"PublisherClient",
85+
"PublisherAsyncClient",
86+
"SchemaServiceClient",
87+
"SchemaServiceAsyncClient",
88+
"SubscriberClient",
89+
"SubscriberAsyncClient",
8490
"AcknowledgeRequest",
85-
"CreateSchemaRequest",
8691
"CreateSnapshotRequest",
8792
"DeadLetterPolicy",
88-
"DeleteSchemaRequest",
8993
"DeleteSnapshotRequest",
9094
"DeleteSubscriptionRequest",
9195
"DeleteTopicRequest",
9296
"DetachSubscriptionRequest",
9397
"DetachSubscriptionResponse",
94-
"Encoding",
9598
"ExpirationPolicy",
96-
"GetSchemaRequest",
9799
"GetSnapshotRequest",
98100
"GetSubscriptionRequest",
99101
"GetTopicRequest",
100-
"ListSchemasRequest",
101-
"ListSchemasResponse",
102102
"ListSnapshotsRequest",
103103
"ListSnapshotsResponse",
104104
"ListSubscriptionsRequest",
105105
"ListSubscriptionsResponse",
106106
"ListTopicSnapshotsRequest",
107107
"ListTopicSnapshotsResponse",
108-
"ListTopicSubscriptionsRequest",
109-
"ListTopicSubscriptionsResponse",
110108
"ListTopicsRequest",
111109
"ListTopicsResponse",
110+
"ListTopicSubscriptionsRequest",
111+
"ListTopicSubscriptionsResponse",
112112
"MessageStoragePolicy",
113113
"ModifyAckDeadlineRequest",
114114
"ModifyPushConfigRequest",
115115
"PublishRequest",
116116
"PublishResponse",
117-
"PublisherAsyncClient",
118-
"PublisherClient",
119117
"PubsubMessage",
120118
"PullRequest",
121119
"PullResponse",
122120
"PushConfig",
123121
"ReceivedMessage",
124122
"RetryPolicy",
125-
"Schema",
126-
"SchemaServiceAsyncClient",
127-
"SchemaServiceClient",
128123
"SchemaSettings",
129-
"SchemaView",
130124
"SeekRequest",
131125
"SeekResponse",
132126
"Snapshot",
133127
"StreamingPullRequest",
134128
"StreamingPullResponse",
135-
"SubscriberAsyncClient",
136-
"SubscriberClient",
137129
"Subscription",
138130
"Topic",
139131
"UpdateSnapshotRequest",
140132
"UpdateSubscriptionRequest",
141133
"UpdateTopicRequest",
134+
"CreateSchemaRequest",
135+
"DeleteSchemaRequest",
136+
"GetSchemaRequest",
137+
"ListSchemasRequest",
138+
"ListSchemasResponse",
139+
"Schema",
142140
"ValidateMessageRequest",
143141
"ValidateMessageResponse",
144142
"ValidateSchemaRequest",
145143
"ValidateSchemaResponse",
144+
"Encoding",
145+
"SchemaView",
146146
)

‎google/pubsub_v1/__init__.py‎

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
# -*- coding: utf-8 -*-
2-
32
# Copyright 2020 Google LLC
43
#
54
# Licensed under the Apache License, Version 2.0 (the "License");
@@ -16,8 +15,12 @@
1615
#
1716

1817
from .services.publisher import PublisherClient
18+
from .services.publisher import PublisherAsyncClient
1919
from .services.schema_service import SchemaServiceClient
20+
from .services.schema_service import SchemaServiceAsyncClient
2021
from .services.subscriber import SubscriberClient
22+
from .services.subscriber import SubscriberAsyncClient
23+
2124
from .types.pubsub import AcknowledgeRequest
2225
from .types.pubsub import CreateSnapshotRequest
2326
from .types.pubsub import DeadLetterPolicy
@@ -36,10 +39,10 @@
3639
from .types.pubsub import ListSubscriptionsResponse
3740
from .types.pubsub import ListTopicSnapshotsRequest
3841
from .types.pubsub import ListTopicSnapshotsResponse
39-
from .types.pubsub import ListTopicSubscriptionsRequest
40-
from .types.pubsub import ListTopicSubscriptionsResponse
4142
from .types.pubsub import ListTopicsRequest
4243
from .types.pubsub import ListTopicsResponse
44+
from .types.pubsub import ListTopicSubscriptionsRequest
45+
from .types.pubsub import ListTopicSubscriptionsResponse
4346
from .types.pubsub import MessageStoragePolicy
4447
from .types.pubsub import ModifyAckDeadlineRequest
4548
from .types.pubsub import ModifyPushConfigRequest
@@ -64,19 +67,21 @@
6467
from .types.pubsub import UpdateTopicRequest
6568
from .types.schema import CreateSchemaRequest
6669
from .types.schema import DeleteSchemaRequest
67-
from .types.schema import Encoding
6870
from .types.schema import GetSchemaRequest
6971
from .types.schema import ListSchemasRequest
7072
from .types.schema import ListSchemasResponse
7173
from .types.schema import Schema
72-
from .types.schema import SchemaView
7374
from .types.schema import ValidateMessageRequest
7475
from .types.schema import ValidateMessageResponse
7576
from .types.schema import ValidateSchemaRequest
7677
from .types.schema import ValidateSchemaResponse
77-
78+
from .types.schema import Encoding
79+
from .types.schema import SchemaView
7880

7981
__all__ = (
82+
"PublisherAsyncClient",
83+
"SchemaServiceAsyncClient",
84+
"SubscriberAsyncClient",
8085
"AcknowledgeRequest",
8186
"CreateSchemaRequest",
8287
"CreateSnapshotRequest",
@@ -110,6 +115,7 @@
110115
"ModifyPushConfigRequest",
111116
"PublishRequest",
112117
"PublishResponse",
118+
"PublisherClient",
113119
"PubsubMessage",
114120
"PullRequest",
115121
"PullResponse",
@@ -135,5 +141,4 @@
135141
"ValidateMessageResponse",
136142
"ValidateSchemaRequest",
137143
"ValidateSchemaResponse",
138-
"PublisherClient",
139144
)

0 commit comments

Comments
 (0)