chore: use gapic-generator-python 0.56.2 (#47)

* chore: update Java and Python dependencies

PiperOrigin-RevId: 408420890

Source-Link: googleapis/googleapis@2921f9f

Source-Link: googleapis/googleapis-gen@6598ca8
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjU5OGNhOGNiYmY1MjI2NzMzYTA5OWM0NTA2NTE4YTVhZjZmZjc0YyJ9

* 🦉 Updates from OwlBot

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>

packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/services/datastream/async_client.py

@@ -19,14 +19,17 @@
 from typing import Dict, Sequence, Tuple, Type, Union
 import pkg_resources
 
-from google.api_core.client_options import ClientOptions  # type: ignore
-from google.api_core import exceptions as core_exceptions  # type: ignore
-from google.api_core import gapic_v1  # type: ignore
-from google.api_core import retry as retries  # type: ignore
+from google.api_core.client_options import ClientOptions
+from google.api_core import exceptions as core_exceptions
+from google.api_core import gapic_v1
+from google.api_core import retry as retries
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
-OptionalRetry = Union[retries.Retry, object]
+try:
+    OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault]
+except AttributeError:  # pragma: NO COVER
+    OptionalRetry = Union[retries.Retry, object]  # type: ignore
 
 from google.api_core import operation  # type: ignore
 from google.api_core import operation_async  # type: ignore

packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/services/datastream/client.py

@@ -14,23 +14,25 @@
 # limitations under the License.
 #
 from collections import OrderedDict
-from distutils import util
 import os
 import re
 from typing import Dict, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
-from google.api_core import client_options as client_options_lib  # type: ignore
-from google.api_core import exceptions as core_exceptions  # type: ignore
-from google.api_core import gapic_v1  # type: ignore
-from google.api_core import retry as retries  # type: ignore
+from google.api_core import client_options as client_options_lib
+from google.api_core import exceptions as core_exceptions
+from google.api_core import gapic_v1
+from google.api_core import retry as retries
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.auth.transport import mtls  # type: ignore
 from google.auth.transport.grpc import SslCredentials  # type: ignore
 from google.auth.exceptions import MutualTLSChannelError  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
-OptionalRetry = Union[retries.Retry, object]
+try:
+    OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault]
+except AttributeError:  # pragma: NO COVER
+    OptionalRetry = Union[retries.Retry, object]  # type: ignore
 
 from google.api_core import operation  # type: ignore
 from google.api_core import operation_async  # type: ignore
@@ -344,8 +346,15 @@ def __init__(
             client_options = client_options_lib.ClientOptions()
 
         # Create SSL credentials for mutual TLS if needed.
-        use_client_cert = bool(
-            util.strtobool(os.getenv("GOOGLE_API_USE_CLIENT_CERTIFICATE", "false"))
+        if os.getenv("GOOGLE_API_USE_CLIENT_CERTIFICATE", "false") not in (
+            "true",
+            "false",
+        ):
+            raise ValueError(
+                "Environment variable `GOOGLE_API_USE_CLIENT_CERTIFICATE` must be either `true` or `false`"
+            )
+        use_client_cert = (
+            os.getenv("GOOGLE_API_USE_CLIENT_CERTIFICATE", "false") == "true"
         )
 
         client_cert_source_func = None

packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/services/datastream/transports/base.py

@@ -18,11 +18,11 @@
 import pkg_resources
 
 import google.auth  # type: ignore
-import google.api_core  # type: ignore
-from google.api_core import exceptions as core_exceptions  # type: ignore
-from google.api_core import gapic_v1  # type: ignore
-from google.api_core import retry as retries  # type: ignore
-from google.api_core import operations_v1  # type: ignore
+import google.api_core
+from google.api_core import exceptions as core_exceptions
+from google.api_core import gapic_v1
+from google.api_core import retry as retries
+from google.api_core import operations_v1
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 

packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc.py

@@ -16,9 +16,9 @@
 import warnings
 from typing import Callable, Dict, Optional, Sequence, Tuple, Union
 
-from google.api_core import grpc_helpers  # type: ignore
-from google.api_core import operations_v1  # type: ignore
-from google.api_core import gapic_v1  # type: ignore
+from google.api_core import grpc_helpers
+from google.api_core import operations_v1
+from google.api_core import gapic_v1
 import google.auth  # type: ignore
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.auth.transport.grpc import SslCredentials  # type: ignore

packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc_asyncio.py

@@ -16,9 +16,9 @@
 import warnings
 from typing import Awaitable, Callable, Dict, Optional, Sequence, Tuple, Union
 
-from google.api_core import gapic_v1  # type: ignore
-from google.api_core import grpc_helpers_async  # type: ignore
-from google.api_core import operations_v1  # type: ignore
+from google.api_core import gapic_v1
+from google.api_core import grpc_helpers_async
+from google.api_core import operations_v1
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.auth.transport.grpc import SslCredentials  # type: ignore
 

packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/types/datastream.py

@@ -72,26 +72,32 @@ class DiscoverConnectionProfileRequest(proto.Message):
             Must be in the format ``projects/*/locations/*``.
         connection_profile (google.cloud.datastream_v1alpha1.types.ConnectionProfile):
             An ad-hoc ConnectionProfile configuration.
+
             This field is a member of `oneof`_ ``target``.
         connection_profile_name (str):
             A reference to an existing ConnectionProfile.
+
             This field is a member of `oneof`_ ``target``.
         recursive (bool):
             Whether to retrieve the full hierarchy of
             data objects (TRUE) or only the current level
             (FALSE).
+
             This field is a member of `oneof`_ ``depth``.
         recursion_depth (int):
             The number of hierarchy levels below the
             current level to be retrieved.
+
             This field is a member of `oneof`_ ``depth``.
         oracle_rdbms (google.cloud.datastream_v1alpha1.types.OracleRdbms):
             Oracle RDBMS to enrich with child data
             objects and metadata.
+
             This field is a member of `oneof`_ ``data_object``.
         mysql_rdbms (google.cloud.datastream_v1alpha1.types.MysqlRdbms):
             MySQL RDBMS to enrich with child data objects
             and metadata.
+
             This field is a member of `oneof`_ ``data_object``.
     """
 
@@ -132,9 +138,11 @@ class DiscoverConnectionProfileResponse(proto.Message):
     Attributes:
         oracle_rdbms (google.cloud.datastream_v1alpha1.types.OracleRdbms):
             Enriched Oracle RDBMS object.
+
             This field is a member of `oneof`_ ``data_object``.
         mysql_rdbms (google.cloud.datastream_v1alpha1.types.MysqlRdbms):
             Enriched MySQL RDBMS object.
+
             This field is a member of `oneof`_ ``data_object``.
     """
 

packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/types/datastream_resources.py

@@ -171,9 +171,11 @@ class ForwardSshTunnelConnectivity(proto.Message):
             Port for the SSH tunnel, default value is 22.
         password (str):
             Input only. SSH password.
+
             This field is a member of `oneof`_ ``authentication_method``.
         private_key (str):
             Input only. SSH private key.
+
             This field is a member of `oneof`_ ``authentication_method``.
     """
 
@@ -346,25 +348,32 @@ class ConnectionProfile(proto.Message):
             Required. Display name.
         oracle_profile (google.cloud.datastream_v1alpha1.types.OracleProfile):
             Oracle ConnectionProfile configuration.
+
             This field is a member of `oneof`_ ``profile``.
         gcs_profile (google.cloud.datastream_v1alpha1.types.GcsProfile):
             Cloud Storage ConnectionProfile
             configuration.
+
             This field is a member of `oneof`_ ``profile``.
         mysql_profile (google.cloud.datastream_v1alpha1.types.MysqlProfile):
             MySQL ConnectionProfile configuration.
+
             This field is a member of `oneof`_ ``profile``.
         no_connectivity (google.cloud.datastream_v1alpha1.types.NoConnectivitySettings):
             No connectivity option chosen.
+
             This field is a member of `oneof`_ ``connectivity``.
         static_service_ip_connectivity (google.cloud.datastream_v1alpha1.types.StaticServiceIpConnectivity):
             Static Service IP connectivity.
+
             This field is a member of `oneof`_ ``connectivity``.
         forward_ssh_connectivity (google.cloud.datastream_v1alpha1.types.ForwardSshTunnelConnectivity):
             Forward SSH tunnel connectivity.
+
             This field is a member of `oneof`_ ``connectivity``.
         private_connectivity (google.cloud.datastream_v1alpha1.types.PrivateConnectivity):
             Private connectivity.
+
             This field is a member of `oneof`_ ``connectivity``.
     """
 
@@ -611,9 +620,11 @@ class SourceConfig(proto.Message):
             identifier.
         oracle_source_config (google.cloud.datastream_v1alpha1.types.OracleSourceConfig):
             Oracle data source configuration
+
             This field is a member of `oneof`_ ``source_stream_config``.
         mysql_source_config (google.cloud.datastream_v1alpha1.types.MysqlSourceConfig):
             MySQL data source configuration
+
             This field is a member of `oneof`_ ``source_stream_config``.
     """
 
@@ -683,9 +694,11 @@ class GcsDestinationConfig(proto.Message):
             created.
         avro_file_format (google.cloud.datastream_v1alpha1.types.AvroFileFormat):
             AVRO file format configuration.
+
             This field is a member of `oneof`_ ``file_format``.
         json_file_format (google.cloud.datastream_v1alpha1.types.JsonFileFormat):
             JSON file format configuration.
+
             This field is a member of `oneof`_ ``file_format``.
     """
 
@@ -760,9 +773,11 @@ class Stream(proto.Message):
             Automatically backfill objects included in
             the stream source configuration. Specific
             objects can be excluded.
+
             This field is a member of `oneof`_ ``backfill_strategy``.
         backfill_none (google.cloud.datastream_v1alpha1.types.Stream.BackfillNoneStrategy):
             Do not automatically backfill any objects.
+
             This field is a member of `oneof`_ ``backfill_strategy``.
         errors (Sequence[google.cloud.datastream_v1alpha1.types.Error]):
             Output only. Errors on the Stream.
@@ -795,10 +810,12 @@ class BackfillAllStrategy(proto.Message):
             oracle_excluded_objects (google.cloud.datastream_v1alpha1.types.OracleRdbms):
                 Oracle data source objects to avoid
                 backfilling.
+
                 This field is a member of `oneof`_ ``excluded_objects``.
             mysql_excluded_objects (google.cloud.datastream_v1alpha1.types.MysqlRdbms):
                 MySQL data source objects to avoid
                 backfilling.
+
                 This field is a member of `oneof`_ ``excluded_objects``.
         """