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

- [ ] Regenerate this pull request now.

PiperOrigin-RevId: 440970084

Source-Link: googleapis/googleapis@5e0a3d5

Source-Link: googleapis/googleapis-gen@b0c628a
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYjBjNjI4YTNmYWRlNzY4ZjIyNWQ3Njk5Mjc5MWVhMWJhMmE4ODFiZSJ9

docs: fix type in docstring for map fields

google/cloud/dataflow_v1beta3/services/flex_templates_service/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

google/cloud/dataflow_v1beta3/services/flex_templates_service/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

google/cloud/dataflow_v1beta3/services/flex_templates_service/transports/base.py

@@ -85,6 +85,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"
@@ -153,5 +154,9 @@ def launch_flex_template(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("FlexTemplatesServiceTransport",)

google/cloud/dataflow_v1beta3/services/flex_templates_service/transports/grpc.py

@@ -259,5 +259,9 @@ def launch_flex_template(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("FlexTemplatesServiceGrpcTransport",)

google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/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
@@ -219,7 +219,6 @@ async def create_job(
         Using ``projects.jobs.create`` is not recommended, as your job
         will always start in ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -292,7 +291,6 @@ async def get_job(
         Using ``projects.jobs.get`` is not recommended, as you can only
         get the state of jobs that are running in ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -366,7 +364,6 @@ async def update_job(
         only update the state of jobs that are running in
         ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -441,7 +438,6 @@ async def list_jobs(
         not recommended, as you can only get the list of jobs that are
         running in ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -613,7 +609,6 @@ async def check_active_jobs(
         r"""Check for existence of active jobs in the given
         project across all regions.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3

google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/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
@@ -425,7 +425,6 @@ def create_job(
         Using ``projects.jobs.create`` is not recommended, as your job
         will always start in ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -499,7 +498,6 @@ def get_job(
         Using ``projects.jobs.get`` is not recommended, as you can only
         get the state of jobs that are running in ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -574,7 +572,6 @@ def update_job(
         only update the state of jobs that are running in
         ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -650,7 +647,6 @@ def list_jobs(
         not recommended, as you can only get the list of jobs that are
         running in ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -824,7 +820,6 @@ def check_active_jobs(
         r"""Check for existence of active jobs in the given
         project across all regions.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3

google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/transports/base.py

@@ -86,6 +86,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"
@@ -226,5 +227,9 @@ def snapshot_job(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("JobsV1Beta3Transport",)

google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/transports/grpc.py

@@ -433,5 +433,9 @@ def snapshot_job(self) -> Callable[[jobs.SnapshotJobRequest], snapshots.Snapshot
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("JobsV1Beta3GrpcTransport",)

google/cloud/dataflow_v1beta3/services/messages_v1_beta3/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
@@ -220,7 +220,6 @@ async def list_job_messages(
         can only request the status of jobs that are running in
         ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3

google/cloud/dataflow_v1beta3/services/messages_v1_beta3/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
@@ -424,7 +424,6 @@ def list_job_messages(
         can only request the status of jobs that are running in
         ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3

google/cloud/dataflow_v1beta3/services/messages_v1_beta3/transports/base.py

@@ -85,6 +85,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"
@@ -153,5 +154,9 @@ def list_job_messages(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("MessagesV1Beta3Transport",)

google/cloud/dataflow_v1beta3/services/messages_v1_beta3/transports/grpc.py

@@ -265,5 +265,9 @@ def list_job_messages(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("MessagesV1Beta3GrpcTransport",)

google/cloud/dataflow_v1beta3/services/metrics_v1_beta3/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
@@ -221,7 +221,6 @@ async def get_job_metrics(
         can only request the status of jobs that are running in
         ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -299,7 +298,6 @@ async def get_job_execution_details(
         EXPERIMENTAL.  This API is subject to change or removal
         without notice.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -383,7 +381,6 @@ async def get_stage_execution_details(
         EXPERIMENTAL.  This API is subject to change or removal
         without notice.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3

google/cloud/dataflow_v1beta3/services/metrics_v1_beta3/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
@@ -425,7 +425,6 @@ def get_job_metrics(
         can only request the status of jobs that are running in
         ``us-central1``.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -504,7 +503,6 @@ def get_job_execution_details(
         EXPERIMENTAL.  This API is subject to change or removal
         without notice.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3
@@ -591,7 +589,6 @@ def get_stage_execution_details(
         EXPERIMENTAL.  This API is subject to change or removal
         without notice.
 
-
         .. code-block:: python
 
             from google.cloud import dataflow_v1beta3

google/cloud/dataflow_v1beta3/services/metrics_v1_beta3/transports/base.py

@@ -85,6 +85,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"
@@ -178,5 +179,9 @@ def get_stage_execution_details(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("MetricsV1Beta3Transport",)

google/cloud/dataflow_v1beta3/services/metrics_v1_beta3/transports/grpc.py

@@ -326,5 +326,9 @@ def get_stage_execution_details(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("MetricsV1Beta3GrpcTransport",)

google/cloud/dataflow_v1beta3/services/snapshots_v1_beta3/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

google/cloud/dataflow_v1beta3/services/snapshots_v1_beta3/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

google/cloud/dataflow_v1beta3/services/snapshots_v1_beta3/transports/base.py

@@ -85,6 +85,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"
@@ -183,5 +184,9 @@ def list_snapshots(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("SnapshotsV1Beta3Transport",)

google/cloud/dataflow_v1beta3/services/snapshots_v1_beta3/transports/grpc.py

@@ -309,5 +309,9 @@ def list_snapshots(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("SnapshotsV1Beta3GrpcTransport",)

google/cloud/dataflow_v1beta3/services/templates_service/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

google/cloud/dataflow_v1beta3/services/templates_service/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