chore: Use gapic-generator-python 0.65.0 (#226)

* chore: Use gapic-generator-python 0.65.0 PiperOrigin-RevId: 440970084 Source-Link: googleapis/googleapis@5e0a3d5 Source-Link: googleapis/googleapis-gen@b0c628a Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYjBjNjI4YTNmYWRlNzY4ZjIyNWQ3Njk5Mjc5MWVhMWJhMmE4ODFiZSJ9 * 🦉 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>
googleapis · Apr 11, 2022 · 3605cb7 · 3605cb7
1 parent 2b9a869
commit 3605cb7
Show file tree

Hide file tree

Showing 10 changed files with 80 additions and 52 deletions.
diff --git a/...google-cloud-scheduler/google/cloud/scheduler_v1/services/cloud_scheduler/async_client.py b/...google-cloud-scheduler/google/cloud/scheduler_v1/services/cloud_scheduler/async_client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions
@@ -297,8 +297,7 @@ def sample_list_jobs():
                 maximum=60.0,
                 multiplier=1.3,
                 predicate=retries.if_exception_type(
-                    core_exceptions.DeadlineExceeded,
-                    core_exceptions.ServiceUnavailable,
+                    core_exceptions.GoogleAPICallError,
                 ),
                 deadline=600.0,
             ),
@@ -412,8 +411,7 @@ def sample_get_job():
                 maximum=60.0,
                 multiplier=1.3,
                 predicate=retries.if_exception_type(
-                    core_exceptions.DeadlineExceeded,
-                    core_exceptions.ServiceUnavailable,
+                    core_exceptions.GoogleAPICallError,
                 ),
                 deadline=600.0,
             ),
@@ -573,7 +571,6 @@ async def update_job(
         retry the UpdateJob request until a successful response is
         received.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1
@@ -743,8 +740,7 @@ def sample_delete_job():
                 maximum=60.0,
                 multiplier=1.3,
                 predicate=retries.if_exception_type(
-                    core_exceptions.DeadlineExceeded,
-                    core_exceptions.ServiceUnavailable,
+                    core_exceptions.GoogleAPICallError,
                 ),
                 deadline=600.0,
             ),
@@ -788,7 +784,6 @@ async def pause_job(
         [Job.State.ENABLED][google.cloud.scheduler.v1.Job.State.ENABLED]
         to be paused.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1
@@ -895,7 +890,6 @@ async def resume_job(
         [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED]
         to be resumed.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1
@@ -994,7 +988,6 @@ async def run_job(
         When this method is called, Cloud Scheduler will
         dispatch the job, even if the job is already running.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1

diff --git a/packages/google-cloud-scheduler/google/cloud/scheduler_v1/services/cloud_scheduler/client.py b/packages/google-cloud-scheduler/google/cloud/scheduler_v1/services/cloud_scheduler/client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib
@@ -792,7 +792,6 @@ def update_job(
         retry the UpdateJob request until a successful response is
         received.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1
@@ -997,7 +996,6 @@ def pause_job(
         [Job.State.ENABLED][google.cloud.scheduler.v1.Job.State.ENABLED]
         to be paused.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1
@@ -1104,7 +1102,6 @@ def resume_job(
         [Job.State.PAUSED][google.cloud.scheduler.v1.Job.State.PAUSED]
         to be resumed.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1
@@ -1203,7 +1200,6 @@ def run_job(
         When this method is called, Cloud Scheduler will
         dispatch the job, even if the job is already running.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1

diff --git a/...gle-cloud-scheduler/google/cloud/scheduler_v1/services/cloud_scheduler/transports/base.py b/...gle-cloud-scheduler/google/cloud/scheduler_v1/services/cloud_scheduler/transports/base.py
@@ -83,6 +83,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -130,8 +131,7 @@ def _prep_wrapped_messages(self, client_info):
                     maximum=60.0,
                     multiplier=1.3,
                     predicate=retries.if_exception_type(
-                        core_exceptions.DeadlineExceeded,
-                        core_exceptions.ServiceUnavailable,
+                        core_exceptions.GoogleAPICallError,
                     ),
                     deadline=600.0,
                 ),
@@ -145,8 +145,7 @@ def _prep_wrapped_messages(self, client_info):
                     maximum=60.0,
                     multiplier=1.3,
                     predicate=retries.if_exception_type(
-                        core_exceptions.DeadlineExceeded,
-                        core_exceptions.ServiceUnavailable,
+                        core_exceptions.GoogleAPICallError,
                     ),
                     deadline=600.0,
                 ),
@@ -170,8 +169,7 @@ def _prep_wrapped_messages(self, client_info):
                     maximum=60.0,
                     multiplier=1.3,
                     predicate=retries.if_exception_type(
-                        core_exceptions.DeadlineExceeded,
-                        core_exceptions.ServiceUnavailable,
+                        core_exceptions.GoogleAPICallError,
                     ),
                     deadline=600.0,
                 ),
@@ -266,5 +264,9 @@ def run_job(
     ) -> Callable[[cloudscheduler.RunJobRequest], Union[job.Job, Awaitable[job.Job]]]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("CloudSchedulerTransport",)
diff --git a/...gle-cloud-scheduler/google/cloud/scheduler_v1/services/cloud_scheduler/transports/grpc.py b/...gle-cloud-scheduler/google/cloud/scheduler_v1/services/cloud_scheduler/transports/grpc.py
@@ -464,5 +464,9 @@ def run_job(self) -> Callable[[cloudscheduler.RunJobRequest], job.Job]:
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("CloudSchedulerGrpcTransport",)
diff --git a/...e-cloud-scheduler/google/cloud/scheduler_v1beta1/services/cloud_scheduler/async_client.py b/...e-cloud-scheduler/google/cloud/scheduler_v1beta1/services/cloud_scheduler/async_client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions
@@ -297,8 +297,7 @@ def sample_list_jobs():
                 maximum=60.0,
                 multiplier=1.3,
                 predicate=retries.if_exception_type(
-                    core_exceptions.DeadlineExceeded,
-                    core_exceptions.ServiceUnavailable,
+                    core_exceptions.GoogleAPICallError,
                 ),
                 deadline=600.0,
             ),
@@ -412,8 +411,7 @@ def sample_get_job():
                 maximum=60.0,
                 multiplier=1.3,
                 predicate=retries.if_exception_type(
-                    core_exceptions.DeadlineExceeded,
-                    core_exceptions.ServiceUnavailable,
+                    core_exceptions.GoogleAPICallError,
                 ),
                 deadline=600.0,
             ),
@@ -574,7 +572,6 @@ async def update_job(
         retry the UpdateJob request until a successful response is
         received.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1beta1
@@ -744,8 +741,7 @@ def sample_delete_job():
                 maximum=60.0,
                 multiplier=1.3,
                 predicate=retries.if_exception_type(
-                    core_exceptions.DeadlineExceeded,
-                    core_exceptions.ServiceUnavailable,
+                    core_exceptions.GoogleAPICallError,
                 ),
                 deadline=600.0,
             ),
@@ -789,7 +785,6 @@ async def pause_job(
         [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]
         to be paused.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1beta1
@@ -859,8 +854,7 @@ def sample_pause_job():
                 maximum=60.0,
                 multiplier=1.3,
                 predicate=retries.if_exception_type(
-                    core_exceptions.DeadlineExceeded,
-                    core_exceptions.ServiceUnavailable,
+                    core_exceptions.GoogleAPICallError,
                 ),
                 deadline=600.0,
             ),
@@ -906,7 +900,6 @@ async def resume_job(
         [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]
         to be resumed.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1beta1
@@ -976,8 +969,7 @@ def sample_resume_job():
                 maximum=60.0,
                 multiplier=1.3,
                 predicate=retries.if_exception_type(
-                    core_exceptions.DeadlineExceeded,
-                    core_exceptions.ServiceUnavailable,
+                    core_exceptions.GoogleAPICallError,
                 ),
                 deadline=600.0,
             ),
@@ -1015,7 +1007,6 @@ async def run_job(
         When this method is called, Cloud Scheduler will
         dispatch the job, even if the job is already running.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1beta1

diff --git a/.../google-cloud-scheduler/google/cloud/scheduler_v1beta1/services/cloud_scheduler/client.py b/.../google-cloud-scheduler/google/cloud/scheduler_v1beta1/services/cloud_scheduler/client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib
@@ -793,7 +793,6 @@ def update_job(
         retry the UpdateJob request until a successful response is
         received.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1beta1
@@ -998,7 +997,6 @@ def pause_job(
         [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]
         to be paused.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1beta1
@@ -1105,7 +1103,6 @@ def resume_job(
         [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]
         to be resumed.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1beta1
@@ -1204,7 +1201,6 @@ def run_job(
         When this method is called, Cloud Scheduler will
         dispatch the job, even if the job is already running.
 
-
         .. code-block:: python
 
             from google.cloud import scheduler_v1beta1

diff --git a/...loud-scheduler/google/cloud/scheduler_v1beta1/services/cloud_scheduler/transports/base.py b/...loud-scheduler/google/cloud/scheduler_v1beta1/services/cloud_scheduler/transports/base.py
@@ -83,6 +83,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -130,8 +131,7 @@ def _prep_wrapped_messages(self, client_info):
                     maximum=60.0,
                     multiplier=1.3,
                     predicate=retries.if_exception_type(
-                        core_exceptions.DeadlineExceeded,
-                        core_exceptions.ServiceUnavailable,
+                        core_exceptions.GoogleAPICallError,
                     ),
                     deadline=600.0,
                 ),
@@ -145,8 +145,7 @@ def _prep_wrapped_messages(self, client_info):
                     maximum=60.0,
                     multiplier=1.3,
                     predicate=retries.if_exception_type(
-                        core_exceptions.DeadlineExceeded,
-                        core_exceptions.ServiceUnavailable,
+                        core_exceptions.GoogleAPICallError,
                     ),
                     deadline=600.0,
                 ),
@@ -170,8 +169,7 @@ def _prep_wrapped_messages(self, client_info):
                     maximum=60.0,
                     multiplier=1.3,
                     predicate=retries.if_exception_type(
-                        core_exceptions.DeadlineExceeded,
-                        core_exceptions.ServiceUnavailable,
+                        core_exceptions.GoogleAPICallError,
                     ),
                     deadline=600.0,
                 ),
@@ -185,8 +183,7 @@ def _prep_wrapped_messages(self, client_info):
                     maximum=60.0,
                     multiplier=1.3,
                     predicate=retries.if_exception_type(
-                        core_exceptions.DeadlineExceeded,
-                        core_exceptions.ServiceUnavailable,
+                        core_exceptions.GoogleAPICallError,
                     ),
                     deadline=600.0,
                 ),
@@ -200,8 +197,7 @@ def _prep_wrapped_messages(self, client_info):
                     maximum=60.0,
                     multiplier=1.3,
                     predicate=retries.if_exception_type(
-                        core_exceptions.DeadlineExceeded,
-                        core_exceptions.ServiceUnavailable,
+                        core_exceptions.GoogleAPICallError,
                     ),
                     deadline=600.0,
                 ),
@@ -286,5 +282,9 @@ def run_job(
     ) -> Callable[[cloudscheduler.RunJobRequest], Union[job.Job, Awaitable[job.Job]]]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("CloudSchedulerTransport",)
diff --git a/...loud-scheduler/google/cloud/scheduler_v1beta1/services/cloud_scheduler/transports/grpc.py b/...loud-scheduler/google/cloud/scheduler_v1beta1/services/cloud_scheduler/transports/grpc.py
@@ -464,5 +464,9 @@ def run_job(self) -> Callable[[cloudscheduler.RunJobRequest], job.Job]:
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("CloudSchedulerGrpcTransport",)