Skip to content

Commit 9021025

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
feat: add cloud storage subscription fields (#918)
* feat: add cloud storage subscription fields PiperOrigin-RevId: 531202368 Source-Link: googleapis/googleapis@8a4cc94 Source-Link: googleapis/googleapis-gen@ec60ad7 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZWM2MGFkNzYzNTZkODhlOTlmYTQ4NDRmYmQ5MGZkY2NhNzI4ZjVjYiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent bd11b29 commit 9021025

File tree

11 files changed

+410
-77
lines changed

11 files changed

+410
-77
lines changed

‎packages/google-cloud-pubsub/google/pubsub/__init__.py‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929

3030
from google.pubsub_v1.types.pubsub import AcknowledgeRequest
3131
from google.pubsub_v1.types.pubsub import BigQueryConfig
32+
from google.pubsub_v1.types.pubsub import CloudStorageConfig
3233
from google.pubsub_v1.types.pubsub import CreateSnapshotRequest
3334
from google.pubsub_v1.types.pubsub import DeadLetterPolicy
3435
from google.pubsub_v1.types.pubsub import DeleteSnapshotRequest
@@ -99,6 +100,7 @@
99100
"SubscriberAsyncClient",
100101
"AcknowledgeRequest",
101102
"BigQueryConfig",
103+
"CloudStorageConfig",
102104
"CreateSnapshotRequest",
103105
"DeadLetterPolicy",
104106
"DeleteSnapshotRequest",

‎packages/google-cloud-pubsub/google/pubsub_v1/__init__.py‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727

2828
from .types.pubsub import AcknowledgeRequest
2929
from .types.pubsub import BigQueryConfig
30+
from .types.pubsub import CloudStorageConfig
3031
from .types.pubsub import CreateSnapshotRequest
3132
from .types.pubsub import DeadLetterPolicy
3233
from .types.pubsub import DeleteSnapshotRequest
@@ -94,6 +95,7 @@
9495
"SubscriberAsyncClient",
9596
"AcknowledgeRequest",
9697
"BigQueryConfig",
98+
"CloudStorageConfig",
9799
"CommitSchemaRequest",
98100
"CreateSchemaRequest",
99101
"CreateSnapshotRequest",

‎packages/google-cloud-pubsub/google/pubsub_v1/services/schema_service/async_client.py‎

Lines changed: 100 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,16 @@ async def sample_create_schema():
326326
# and friendly error handling.
327327
rpc = gapic_v1.method_async.wrap_method(
328328
self._client._transport.create_schema,
329-
default_timeout=None,
329+
default_retry=retries.Retry(
330+
initial=0.1,
331+
maximum=60.0,
332+
multiplier=1.3,
333+
predicate=retries.if_exception_type(
334+
core_exceptions.ServiceUnavailable,
335+
),
336+
deadline=60.0,
337+
),
338+
default_timeout=60.0,
330339
client_info=DEFAULT_CLIENT_INFO,
331340
)
332341

@@ -425,7 +434,16 @@ async def sample_get_schema():
425434
# and friendly error handling.
426435
rpc = gapic_v1.method_async.wrap_method(
427436
self._client._transport.get_schema,
428-
default_timeout=None,
437+
default_retry=retries.Retry(
438+
initial=0.1,
439+
maximum=60.0,
440+
multiplier=1.3,
441+
predicate=retries.if_exception_type(
442+
core_exceptions.ServiceUnavailable,
443+
),
444+
deadline=60.0,
445+
),
446+
default_timeout=60.0,
429447
client_info=DEFAULT_CLIENT_INFO,
430448
)
431449

@@ -529,7 +547,16 @@ async def sample_list_schemas():
529547
# and friendly error handling.
530548
rpc = gapic_v1.method_async.wrap_method(
531549
self._client._transport.list_schemas,
532-
default_timeout=None,
550+
default_retry=retries.Retry(
551+
initial=0.1,
552+
maximum=60.0,
553+
multiplier=1.3,
554+
predicate=retries.if_exception_type(
555+
core_exceptions.ServiceUnavailable,
556+
),
557+
deadline=60.0,
558+
),
559+
default_timeout=60.0,
533560
client_info=DEFAULT_CLIENT_INFO,
534561
)
535562

@@ -642,7 +669,16 @@ async def sample_list_schema_revisions():
642669
# and friendly error handling.
643670
rpc = gapic_v1.method_async.wrap_method(
644671
self._client._transport.list_schema_revisions,
645-
default_timeout=None,
672+
default_retry=retries.Retry(
673+
initial=0.1,
674+
maximum=60.0,
675+
multiplier=1.3,
676+
predicate=retries.if_exception_type(
677+
core_exceptions.ServiceUnavailable,
678+
),
679+
deadline=60.0,
680+
),
681+
default_timeout=60.0,
646682
client_info=DEFAULT_CLIENT_INFO,
647683
)
648684

@@ -764,7 +800,16 @@ async def sample_commit_schema():
764800
# and friendly error handling.
765801
rpc = gapic_v1.method_async.wrap_method(
766802
self._client._transport.commit_schema,
767-
default_timeout=None,
803+
default_retry=retries.Retry(
804+
initial=0.1,
805+
maximum=60.0,
806+
multiplier=1.3,
807+
predicate=retries.if_exception_type(
808+
core_exceptions.ServiceUnavailable,
809+
),
810+
deadline=60.0,
811+
),
812+
default_timeout=60.0,
768813
client_info=DEFAULT_CLIENT_INFO,
769814
)
770815

@@ -877,7 +922,16 @@ async def sample_rollback_schema():
877922
# and friendly error handling.
878923
rpc = gapic_v1.method_async.wrap_method(
879924
self._client._transport.rollback_schema,
880-
default_timeout=None,
925+
default_retry=retries.Retry(
926+
initial=0.1,
927+
maximum=60.0,
928+
multiplier=1.3,
929+
predicate=retries.if_exception_type(
930+
core_exceptions.ServiceUnavailable,
931+
),
932+
deadline=60.0,
933+
),
934+
default_timeout=60.0,
881935
client_info=DEFAULT_CLIENT_INFO,
882936
)
883937

@@ -989,7 +1043,16 @@ async def sample_delete_schema_revision():
9891043
# and friendly error handling.
9901044
rpc = gapic_v1.method_async.wrap_method(
9911045
self._client._transport.delete_schema_revision,
992-
default_timeout=None,
1046+
default_retry=retries.Retry(
1047+
initial=0.1,
1048+
maximum=60.0,
1049+
multiplier=1.3,
1050+
predicate=retries.if_exception_type(
1051+
core_exceptions.ServiceUnavailable,
1052+
),
1053+
deadline=60.0,
1054+
),
1055+
default_timeout=60.0,
9931056
client_info=DEFAULT_CLIENT_INFO,
9941057
)
9951058

@@ -1081,7 +1144,16 @@ async def sample_delete_schema():
10811144
# and friendly error handling.
10821145
rpc = gapic_v1.method_async.wrap_method(
10831146
self._client._transport.delete_schema,
1084-
default_timeout=None,
1147+
default_retry=retries.Retry(
1148+
initial=0.1,
1149+
maximum=60.0,
1150+
multiplier=1.3,
1151+
predicate=retries.if_exception_type(
1152+
core_exceptions.ServiceUnavailable,
1153+
),
1154+
deadline=60.0,
1155+
),
1156+
default_timeout=60.0,
10851157
client_info=DEFAULT_CLIENT_INFO,
10861158
)
10871159

@@ -1193,7 +1265,16 @@ async def sample_validate_schema():
11931265
# and friendly error handling.
11941266
rpc = gapic_v1.method_async.wrap_method(
11951267
self._client._transport.validate_schema,
1196-
default_timeout=None,
1268+
default_retry=retries.Retry(
1269+
initial=0.1,
1270+
maximum=60.0,
1271+
multiplier=1.3,
1272+
predicate=retries.if_exception_type(
1273+
core_exceptions.ServiceUnavailable,
1274+
),
1275+
deadline=60.0,
1276+
),
1277+
default_timeout=60.0,
11971278
client_info=DEFAULT_CLIENT_INFO,
11981279
)
11991280

@@ -1273,7 +1354,16 @@ async def sample_validate_message():
12731354
# and friendly error handling.
12741355
rpc = gapic_v1.method_async.wrap_method(
12751356
self._client._transport.validate_message,
1276-
default_timeout=None,
1357+
default_retry=retries.Retry(
1358+
initial=0.1,
1359+
maximum=60.0,
1360+
multiplier=1.3,
1361+
predicate=retries.if_exception_type(
1362+
core_exceptions.ServiceUnavailable,
1363+
),
1364+
deadline=60.0,
1365+
),
1366+
default_timeout=60.0,
12771367
client_info=DEFAULT_CLIENT_INFO,
12781368
)
12791369

‎packages/google-cloud-pubsub/google/pubsub_v1/services/schema_service/transports/base.py‎

Lines changed: 100 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -132,52 +132,142 @@ def _prep_wrapped_messages(self, client_info):
132132
self._wrapped_methods = {
133133
self.create_schema: gapic_v1.method.wrap_method(
134134
self.create_schema,
135-
default_timeout=None,
135+
default_retry=retries.Retry(
136+
initial=0.1,
137+
maximum=60.0,
138+
multiplier=1.3,
139+
predicate=retries.if_exception_type(
140+
core_exceptions.ServiceUnavailable,
141+
),
142+
deadline=60.0,
143+
),
144+
default_timeout=60.0,
136145
client_info=client_info,
137146
),
138147
self.get_schema: gapic_v1.method.wrap_method(
139148
self.get_schema,
140-
default_timeout=None,
149+
default_retry=retries.Retry(
150+
initial=0.1,
151+
maximum=60.0,
152+
multiplier=1.3,
153+
predicate=retries.if_exception_type(
154+
core_exceptions.ServiceUnavailable,
155+
),
156+
deadline=60.0,
157+
),
158+
default_timeout=60.0,
141159
client_info=client_info,
142160
),
143161
self.list_schemas: gapic_v1.method.wrap_method(
144162
self.list_schemas,
145-
default_timeout=None,
163+
default_retry=retries.Retry(
164+
initial=0.1,
165+
maximum=60.0,
166+
multiplier=1.3,
167+
predicate=retries.if_exception_type(
168+
core_exceptions.ServiceUnavailable,
169+
),
170+
deadline=60.0,
171+
),
172+
default_timeout=60.0,
146173
client_info=client_info,
147174
),
148175
self.list_schema_revisions: gapic_v1.method.wrap_method(
149176
self.list_schema_revisions,
150-
default_timeout=None,
177+
default_retry=retries.Retry(
178+
initial=0.1,
179+
maximum=60.0,
180+
multiplier=1.3,
181+
predicate=retries.if_exception_type(
182+
core_exceptions.ServiceUnavailable,
183+
),
184+
deadline=60.0,
185+
),
186+
default_timeout=60.0,
151187
client_info=client_info,
152188
),
153189
self.commit_schema: gapic_v1.method.wrap_method(
154190
self.commit_schema,
155-
default_timeout=None,
191+
default_retry=retries.Retry(
192+
initial=0.1,
193+
maximum=60.0,
194+
multiplier=1.3,
195+
predicate=retries.if_exception_type(
196+
core_exceptions.ServiceUnavailable,
197+
),
198+
deadline=60.0,
199+
),
200+
default_timeout=60.0,
156201
client_info=client_info,
157202
),
158203
self.rollback_schema: gapic_v1.method.wrap_method(
159204
self.rollback_schema,
160-
default_timeout=None,
205+
default_retry=retries.Retry(
206+
initial=0.1,
207+
maximum=60.0,
208+
multiplier=1.3,
209+
predicate=retries.if_exception_type(
210+
core_exceptions.ServiceUnavailable,
211+
),
212+
deadline=60.0,
213+
),
214+
default_timeout=60.0,
161215
client_info=client_info,
162216
),
163217
self.delete_schema_revision: gapic_v1.method.wrap_method(
164218
self.delete_schema_revision,
165-
default_timeout=None,
219+
default_retry=retries.Retry(
220+
initial=0.1,
221+
maximum=60.0,
222+
multiplier=1.3,
223+
predicate=retries.if_exception_type(
224+
core_exceptions.ServiceUnavailable,
225+
),
226+
deadline=60.0,
227+
),
228+
default_timeout=60.0,
166229
client_info=client_info,
167230
),
168231
self.delete_schema: gapic_v1.method.wrap_method(
169232
self.delete_schema,
170-
default_timeout=None,
233+
default_retry=retries.Retry(
234+
initial=0.1,
235+
maximum=60.0,
236+
multiplier=1.3,
237+
predicate=retries.if_exception_type(
238+
core_exceptions.ServiceUnavailable,
239+
),
240+
deadline=60.0,
241+
),
242+
default_timeout=60.0,
171243
client_info=client_info,
172244
),
173245
self.validate_schema: gapic_v1.method.wrap_method(
174246
self.validate_schema,
175-
default_timeout=None,
247+
default_retry=retries.Retry(
248+
initial=0.1,
249+
maximum=60.0,
250+
multiplier=1.3,
251+
predicate=retries.if_exception_type(
252+
core_exceptions.ServiceUnavailable,
253+
),
254+
deadline=60.0,
255+
),
256+
default_timeout=60.0,
176257
client_info=client_info,
177258
),
178259
self.validate_message: gapic_v1.method.wrap_method(
179260
self.validate_message,
180-
default_timeout=None,
261+
default_retry=retries.Retry(
262+
initial=0.1,
263+
maximum=60.0,
264+
multiplier=1.3,
265+
predicate=retries.if_exception_type(
266+
core_exceptions.ServiceUnavailable,
267+
),
268+
deadline=60.0,
269+
),
270+
default_timeout=60.0,
181271
client_info=client_info,
182272
),
183273
}

0 commit comments

Comments
 (0)