chore: Update gapic-generator-python to v1.7.1 (#162)

* chore: Update gapic-generator-python to v1.7.1 PiperOrigin-RevId: 495049888 Source-Link: googleapis/googleapis@bf4359c Source-Link: googleapis/googleapis-gen@5ab9576 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNWFiOTU3NmVhZmJkNGRlNDM2ODk2ZjAxYzI3ODc1N2Q4N2EyNGUyNyJ9 * 🦉 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 · Dec 14, 2022 · 7695d1c · 7695d1c
1 parent 7bdfed5
commit 7695d1c
Show file tree

Hide file tree

Showing 6 changed files with 54 additions and 60 deletions.
diff --git a/...w-client/google/cloud/dataflow_v1beta3/services/flex_templates_service/transports/rest.py b/...w-client/google/cloud/dataflow_v1beta3/services/flex_templates_service/transports/rest.py
@@ -47,10 +47,6 @@
     rest_version=requests_version,
 )
 
-# TODO (numeric enums): This file was generated with the option to
-#   request that the server respond with enums JSON-encoded as
-#   numbers. The code below does not implement that functionality yet.
-
 
 class FlexTemplatesServiceRestInterceptor:
     """Interceptor for FlexTemplatesService.
@@ -67,12 +63,13 @@ class FlexTemplatesServiceRestInterceptor:
 
     .. code-block:: python
         class MyCustomFlexTemplatesServiceInterceptor(FlexTemplatesServiceRestInterceptor):
-            def pre_launch_flex_template(request, metadata):
+            def pre_launch_flex_template(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_launch_flex_template(response):
+            def post_launch_flex_template(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
         transport = FlexTemplatesServiceRestTransport(interceptor=MyCustomFlexTemplatesServiceInterceptor())
         client = FlexTemplatesServiceClient(transport=transport)

diff --git a/...d-dataflow-client/google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/transports/rest.py b/...d-dataflow-client/google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/transports/rest.py
@@ -47,10 +47,6 @@
     rest_version=requests_version,
 )
 
-# TODO (numeric enums): This file was generated with the option to
-#   request that the server respond with enums JSON-encoded as
-#   numbers. The code below does not implement that functionality yet.
-
 
 class JobsV1Beta3RestInterceptor:
     """Interceptor for JobsV1Beta3.
@@ -67,54 +63,61 @@ class JobsV1Beta3RestInterceptor:
 
     .. code-block:: python
         class MyCustomJobsV1Beta3Interceptor(JobsV1Beta3RestInterceptor):
-            def pre_aggregated_list_jobs(request, metadata):
+            def pre_aggregated_list_jobs(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_aggregated_list_jobs(response):
+            def post_aggregated_list_jobs(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_check_active_jobs(request, metadata):
+            def pre_check_active_jobs(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_check_active_jobs(response):
+            def post_check_active_jobs(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_create_job(request, metadata):
+            def pre_create_job(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_create_job(response):
+            def post_create_job(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_get_job(request, metadata):
+            def pre_get_job(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_get_job(response):
+            def post_get_job(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_list_jobs(request, metadata):
+            def pre_list_jobs(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_list_jobs(response):
+            def post_list_jobs(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_snapshot_job(request, metadata):
+            def pre_snapshot_job(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_snapshot_job(response):
+            def post_snapshot_job(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_update_job(request, metadata):
+            def pre_update_job(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_update_job(response):
+            def post_update_job(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
         transport = JobsV1Beta3RestTransport(interceptor=MyCustomJobsV1Beta3Interceptor())
         client = JobsV1Beta3Client(transport=transport)

diff --git a/...taflow-client/google/cloud/dataflow_v1beta3/services/messages_v1_beta3/transports/rest.py b/...taflow-client/google/cloud/dataflow_v1beta3/services/messages_v1_beta3/transports/rest.py
@@ -47,10 +47,6 @@
     rest_version=requests_version,
 )
 
-# TODO (numeric enums): This file was generated with the option to
-#   request that the server respond with enums JSON-encoded as
-#   numbers. The code below does not implement that functionality yet.
-
 
 class MessagesV1Beta3RestInterceptor:
     """Interceptor for MessagesV1Beta3.
@@ -67,12 +63,13 @@ class MessagesV1Beta3RestInterceptor:
 
     .. code-block:: python
         class MyCustomMessagesV1Beta3Interceptor(MessagesV1Beta3RestInterceptor):
-            def pre_list_job_messages(request, metadata):
+            def pre_list_job_messages(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_list_job_messages(response):
+            def post_list_job_messages(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
         transport = MessagesV1Beta3RestTransport(interceptor=MyCustomMessagesV1Beta3Interceptor())
         client = MessagesV1Beta3Client(transport=transport)

diff --git a/...ataflow-client/google/cloud/dataflow_v1beta3/services/metrics_v1_beta3/transports/rest.py b/...ataflow-client/google/cloud/dataflow_v1beta3/services/metrics_v1_beta3/transports/rest.py
@@ -47,10 +47,6 @@
     rest_version=requests_version,
 )
 
-# TODO (numeric enums): This file was generated with the option to
-#   request that the server respond with enums JSON-encoded as
-#   numbers. The code below does not implement that functionality yet.
-
 
 class MetricsV1Beta3RestInterceptor:
     """Interceptor for MetricsV1Beta3.
@@ -67,26 +63,29 @@ class MetricsV1Beta3RestInterceptor:
 
     .. code-block:: python
         class MyCustomMetricsV1Beta3Interceptor(MetricsV1Beta3RestInterceptor):
-            def pre_get_job_execution_details(request, metadata):
+            def pre_get_job_execution_details(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_get_job_execution_details(response):
+            def post_get_job_execution_details(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_get_job_metrics(request, metadata):
+            def pre_get_job_metrics(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_get_job_metrics(response):
+            def post_get_job_metrics(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_get_stage_execution_details(request, metadata):
+            def pre_get_stage_execution_details(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_get_stage_execution_details(response):
+            def post_get_stage_execution_details(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
         transport = MetricsV1Beta3RestTransport(interceptor=MyCustomMetricsV1Beta3Interceptor())
         client = MetricsV1Beta3Client(transport=transport)

diff --git a/...aflow-client/google/cloud/dataflow_v1beta3/services/snapshots_v1_beta3/transports/rest.py b/...aflow-client/google/cloud/dataflow_v1beta3/services/snapshots_v1_beta3/transports/rest.py
@@ -47,10 +47,6 @@
     rest_version=requests_version,
 )
 
-# TODO (numeric enums): This file was generated with the option to
-#   request that the server respond with enums JSON-encoded as
-#   numbers. The code below does not implement that functionality yet.
-
 
 class SnapshotsV1Beta3RestInterceptor:
     """Interceptor for SnapshotsV1Beta3.
@@ -67,26 +63,29 @@ class SnapshotsV1Beta3RestInterceptor:
 
     .. code-block:: python
         class MyCustomSnapshotsV1Beta3Interceptor(SnapshotsV1Beta3RestInterceptor):
-            def pre_delete_snapshot(request, metadata):
+            def pre_delete_snapshot(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_delete_snapshot(response):
+            def post_delete_snapshot(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_get_snapshot(request, metadata):
+            def pre_get_snapshot(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_get_snapshot(response):
+            def post_get_snapshot(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_list_snapshots(request, metadata):
+            def pre_list_snapshots(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_list_snapshots(response):
+            def post_list_snapshots(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
         transport = SnapshotsV1Beta3RestTransport(interceptor=MyCustomSnapshotsV1Beta3Interceptor())
         client = SnapshotsV1Beta3Client(transport=transport)

diff --git a/...taflow-client/google/cloud/dataflow_v1beta3/services/templates_service/transports/rest.py b/...taflow-client/google/cloud/dataflow_v1beta3/services/templates_service/transports/rest.py
@@ -47,10 +47,6 @@
     rest_version=requests_version,
 )
 
-# TODO (numeric enums): This file was generated with the option to
-#   request that the server respond with enums JSON-encoded as
-#   numbers. The code below does not implement that functionality yet.
-
 
 class TemplatesServiceRestInterceptor:
     """Interceptor for TemplatesService.
@@ -67,26 +63,29 @@ class TemplatesServiceRestInterceptor:
 
     .. code-block:: python
         class MyCustomTemplatesServiceInterceptor(TemplatesServiceRestInterceptor):
-            def pre_create_job_from_template(request, metadata):
+            def pre_create_job_from_template(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_create_job_from_template(response):
+            def post_create_job_from_template(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_get_template(request, metadata):
+            def pre_get_template(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_get_template(response):
+            def post_get_template(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
-            def pre_launch_template(request, metadata):
+            def pre_launch_template(self, request, metadata):
                 logging.log(f"Received request: {request}")
                 return request, metadata
 
-            def post_launch_template(response):
+            def post_launch_template(self, response):
                 logging.log(f"Received response: {response}")
+                return response
 
         transport = TemplatesServiceRestTransport(interceptor=MyCustomTemplatesServiceInterceptor())
         client = TemplatesServiceClient(transport=transport)