diff --git a/google/cloud/apigee_registry_v1/services/registry/async_client.py b/google/cloud/apigee_registry_v1/services/registry/async_client.py index 38482a8..dbf28b5 100644 --- a/google/cloud/apigee_registry_v1/services/registry/async_client.py +++ b/google/cloud/apigee_registry_v1/services/registry/async_client.py @@ -290,10 +290,13 @@ async def sample_list_apis(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.list_apis, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -403,10 +406,13 @@ async def sample_get_api(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.get_api, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -531,10 +537,13 @@ async def sample_create_api(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.create_api, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -649,10 +658,13 @@ async def sample_update_api(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.update_api, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -744,10 +756,13 @@ async def sample_delete_api(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.delete_api, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -847,10 +862,13 @@ async def sample_list_api_versions(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.list_api_versions, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -960,10 +978,13 @@ async def sample_get_api_version(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.get_api_version, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -1090,10 +1111,13 @@ async def sample_create_api_version(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.create_api_version, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -1210,10 +1234,13 @@ async def sample_update_api_version(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.update_api_version, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -1308,10 +1335,13 @@ async def sample_delete_api_version(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.delete_api_version, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -1412,10 +1442,13 @@ async def sample_list_api_specs(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.list_api_specs, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -1536,10 +1569,13 @@ async def sample_get_api_spec(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.get_api_spec, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -1688,10 +1724,13 @@ async def sample_get_api_spec_contents(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.get_api_spec_contents, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -1828,10 +1867,13 @@ async def sample_create_api_spec(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.create_api_spec, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -1958,10 +2000,13 @@ async def sample_update_api_spec(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.update_api_spec, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -2055,10 +2100,13 @@ async def sample_delete_api_spec(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.delete_api_spec, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -2147,10 +2195,13 @@ async def sample_tag_api_spec_revision(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.tag_api_spec_revision, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -2235,10 +2286,13 @@ async def sample_list_api_spec_revisions(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.list_api_spec_revisions, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -2450,10 +2504,13 @@ async def sample_delete_api_spec_revision(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.delete_api_spec_revision, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -2558,10 +2615,13 @@ async def sample_list_api_deployments(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.list_api_deployments, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -2678,10 +2738,13 @@ async def sample_get_api_deployment(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.get_api_deployment, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -2814,10 +2877,13 @@ async def sample_create_api_deployment(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.create_api_deployment, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -2940,10 +3006,13 @@ async def sample_update_api_deployment(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.update_api_deployment, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -3038,10 +3107,13 @@ async def sample_delete_api_deployment(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.delete_api_deployment, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -3126,10 +3198,13 @@ async def sample_tag_api_deployment_revision(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.tag_api_deployment_revision, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -3214,10 +3289,13 @@ async def sample_list_api_deployment_revisions(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.list_api_deployment_revisions, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -3422,10 +3500,13 @@ async def sample_delete_api_deployment_revision(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.delete_api_deployment_revision, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -3528,10 +3609,13 @@ async def sample_list_artifacts(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.list_artifacts, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -3649,10 +3733,13 @@ async def sample_get_artifact(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.get_artifact, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -3800,10 +3887,13 @@ async def sample_get_artifact_contents(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.get_artifact_contents, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -3937,10 +4027,13 @@ async def sample_create_artifact(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.create_artifact, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -4050,10 +4143,13 @@ async def sample_replace_artifact(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.replace_artifact, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -4146,10 +4242,13 @@ async def sample_delete_artifact(): rpc = gapic_v1.method_async.wrap_method( self._client._transport.delete_artifact, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, diff --git a/google/cloud/apigee_registry_v1/services/registry/transports/base.py b/google/cloud/apigee_registry_v1/services/registry/transports/base.py index 05c29e9..54d5bd9 100644 --- a/google/cloud/apigee_registry_v1/services/registry/transports/base.py +++ b/google/cloud/apigee_registry_v1/services/registry/transports/base.py @@ -137,10 +137,13 @@ def _prep_wrapped_messages(self, client_info): self.list_apis: gapic_v1.method.wrap_method( self.list_apis, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -151,10 +154,13 @@ def _prep_wrapped_messages(self, client_info): self.get_api: gapic_v1.method.wrap_method( self.get_api, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -165,10 +171,13 @@ def _prep_wrapped_messages(self, client_info): self.create_api: gapic_v1.method.wrap_method( self.create_api, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -179,10 +188,13 @@ def _prep_wrapped_messages(self, client_info): self.update_api: gapic_v1.method.wrap_method( self.update_api, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -193,10 +205,13 @@ def _prep_wrapped_messages(self, client_info): self.delete_api: gapic_v1.method.wrap_method( self.delete_api, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -207,10 +222,13 @@ def _prep_wrapped_messages(self, client_info): self.list_api_versions: gapic_v1.method.wrap_method( self.list_api_versions, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -221,10 +239,13 @@ def _prep_wrapped_messages(self, client_info): self.get_api_version: gapic_v1.method.wrap_method( self.get_api_version, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -235,10 +256,13 @@ def _prep_wrapped_messages(self, client_info): self.create_api_version: gapic_v1.method.wrap_method( self.create_api_version, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -249,10 +273,13 @@ def _prep_wrapped_messages(self, client_info): self.update_api_version: gapic_v1.method.wrap_method( self.update_api_version, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -263,10 +290,13 @@ def _prep_wrapped_messages(self, client_info): self.delete_api_version: gapic_v1.method.wrap_method( self.delete_api_version, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -277,10 +307,13 @@ def _prep_wrapped_messages(self, client_info): self.list_api_specs: gapic_v1.method.wrap_method( self.list_api_specs, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -291,10 +324,13 @@ def _prep_wrapped_messages(self, client_info): self.get_api_spec: gapic_v1.method.wrap_method( self.get_api_spec, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -305,10 +341,13 @@ def _prep_wrapped_messages(self, client_info): self.get_api_spec_contents: gapic_v1.method.wrap_method( self.get_api_spec_contents, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -319,10 +358,13 @@ def _prep_wrapped_messages(self, client_info): self.create_api_spec: gapic_v1.method.wrap_method( self.create_api_spec, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -333,10 +375,13 @@ def _prep_wrapped_messages(self, client_info): self.update_api_spec: gapic_v1.method.wrap_method( self.update_api_spec, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -347,10 +392,13 @@ def _prep_wrapped_messages(self, client_info): self.delete_api_spec: gapic_v1.method.wrap_method( self.delete_api_spec, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -361,10 +409,13 @@ def _prep_wrapped_messages(self, client_info): self.tag_api_spec_revision: gapic_v1.method.wrap_method( self.tag_api_spec_revision, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -375,10 +426,13 @@ def _prep_wrapped_messages(self, client_info): self.list_api_spec_revisions: gapic_v1.method.wrap_method( self.list_api_spec_revisions, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -394,10 +448,13 @@ def _prep_wrapped_messages(self, client_info): self.delete_api_spec_revision: gapic_v1.method.wrap_method( self.delete_api_spec_revision, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -408,10 +465,13 @@ def _prep_wrapped_messages(self, client_info): self.list_api_deployments: gapic_v1.method.wrap_method( self.list_api_deployments, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -422,10 +482,13 @@ def _prep_wrapped_messages(self, client_info): self.get_api_deployment: gapic_v1.method.wrap_method( self.get_api_deployment, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -436,10 +499,13 @@ def _prep_wrapped_messages(self, client_info): self.create_api_deployment: gapic_v1.method.wrap_method( self.create_api_deployment, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -450,10 +516,13 @@ def _prep_wrapped_messages(self, client_info): self.update_api_deployment: gapic_v1.method.wrap_method( self.update_api_deployment, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -464,10 +533,13 @@ def _prep_wrapped_messages(self, client_info): self.delete_api_deployment: gapic_v1.method.wrap_method( self.delete_api_deployment, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -478,10 +550,13 @@ def _prep_wrapped_messages(self, client_info): self.tag_api_deployment_revision: gapic_v1.method.wrap_method( self.tag_api_deployment_revision, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -492,10 +567,13 @@ def _prep_wrapped_messages(self, client_info): self.list_api_deployment_revisions: gapic_v1.method.wrap_method( self.list_api_deployment_revisions, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -511,10 +589,13 @@ def _prep_wrapped_messages(self, client_info): self.delete_api_deployment_revision: gapic_v1.method.wrap_method( self.delete_api_deployment_revision, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -525,10 +606,13 @@ def _prep_wrapped_messages(self, client_info): self.list_artifacts: gapic_v1.method.wrap_method( self.list_artifacts, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -539,10 +623,13 @@ def _prep_wrapped_messages(self, client_info): self.get_artifact: gapic_v1.method.wrap_method( self.get_artifact, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -553,10 +640,13 @@ def _prep_wrapped_messages(self, client_info): self.get_artifact_contents: gapic_v1.method.wrap_method( self.get_artifact_contents, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -567,10 +657,13 @@ def _prep_wrapped_messages(self, client_info): self.create_artifact: gapic_v1.method.wrap_method( self.create_artifact, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -581,10 +674,13 @@ def _prep_wrapped_messages(self, client_info): self.replace_artifact: gapic_v1.method.wrap_method( self.replace_artifact, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0, @@ -595,10 +691,13 @@ def _prep_wrapped_messages(self, client_info): self.delete_artifact: gapic_v1.method.wrap_method( self.delete_artifact, default_retry=retries.Retry( - initial=1.0, + initial=0.2, maximum=60.0, multiplier=1.3, predicate=retries.if_exception_type( + core_exceptions.Aborted, + core_exceptions.Cancelled, + core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable, ), deadline=60.0,