Skip to content

Commit 9ccddc7

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
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>
1 parent 1fdfe62 commit 9ccddc7

8 files changed

Lines changed: 235 additions & 94 deletions

File tree

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

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,14 +19,17 @@
1919
from typing import Dict, Sequence, Tuple, Type, Union
2020
import pkg_resources
2121

22-
from google.api_core.client_options import ClientOptions # type: ignore
23-
from google.api_core import exceptions as core_exceptions # type: ignore
24-
from google.api_core import gapic_v1 # type: ignore
25-
from google.api_core import retry as retries # type: ignore
22+
from google.api_core.client_options import ClientOptions
23+
from google.api_core import exceptions as core_exceptions
24+
from google.api_core import gapic_v1
25+
from google.api_core import retry as retries
2626
from google.auth import credentials as ga_credentials # type: ignore
2727
from google.oauth2 import service_account # type: ignore
2828

29-
OptionalRetry = Union[retries.Retry, object]
29+
try:
30+
OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault]
31+
except AttributeError: # pragma: NO COVER
32+
OptionalRetry = Union[retries.Retry, object] # type: ignore
3033

3134
from google.api_core import operation # type: ignore
3235
from google.api_core import operation_async # type: ignore

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

Lines changed: 17 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -14,23 +14,25 @@
1414
# limitations under the License.
1515
#
1616
from collections import OrderedDict
17-
from distutils import util
1817
import os
1918
import re
2019
from typing import Dict, Optional, Sequence, Tuple, Type, Union
2120
import pkg_resources
2221

23-
from google.api_core import client_options as client_options_lib # type: ignore
24-
from google.api_core import exceptions as core_exceptions # type: ignore
25-
from google.api_core import gapic_v1 # type: ignore
26-
from google.api_core import retry as retries # type: ignore
22+
from google.api_core import client_options as client_options_lib
23+
from google.api_core import exceptions as core_exceptions
24+
from google.api_core import gapic_v1
25+
from google.api_core import retry as retries
2726
from google.auth import credentials as ga_credentials # type: ignore
2827
from google.auth.transport import mtls # type: ignore
2928
from google.auth.transport.grpc import SslCredentials # type: ignore
3029
from google.auth.exceptions import MutualTLSChannelError # type: ignore
3130
from google.oauth2 import service_account # type: ignore
3231

33-
OptionalRetry = Union[retries.Retry, object]
32+
try:
33+
OptionalRetry = Union[retries.Retry, gapic_v1.method._MethodDefault]
34+
except AttributeError: # pragma: NO COVER
35+
OptionalRetry = Union[retries.Retry, object] # type: ignore
3436

3537
from google.api_core import operation # type: ignore
3638
from google.api_core import operation_async # type: ignore
@@ -344,8 +346,15 @@ def __init__(
344346
client_options = client_options_lib.ClientOptions()
345347

346348
# Create SSL credentials for mutual TLS if needed.
347-
use_client_cert = bool(
348-
util.strtobool(os.getenv("GOOGLE_API_USE_CLIENT_CERTIFICATE", "false"))
349+
if os.getenv("GOOGLE_API_USE_CLIENT_CERTIFICATE", "false") not in (
350+
"true",
351+
"false",
352+
):
353+
raise ValueError(
354+
"Environment variable `GOOGLE_API_USE_CLIENT_CERTIFICATE` must be either `true` or `false`"
355+
)
356+
use_client_cert = (
357+
os.getenv("GOOGLE_API_USE_CLIENT_CERTIFICATE", "false") == "true"
349358
)
350359

351360
client_cert_source_func = None

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,11 @@
1818
import pkg_resources
1919

2020
import google.auth # type: ignore
21-
import google.api_core # type: ignore
22-
from google.api_core import exceptions as core_exceptions # type: ignore
23-
from google.api_core import gapic_v1 # type: ignore
24-
from google.api_core import retry as retries # type: ignore
25-
from google.api_core import operations_v1 # type: ignore
21+
import google.api_core
22+
from google.api_core import exceptions as core_exceptions
23+
from google.api_core import gapic_v1
24+
from google.api_core import retry as retries
25+
from google.api_core import operations_v1
2626
from google.auth import credentials as ga_credentials # type: ignore
2727
from google.oauth2 import service_account # type: ignore
2828

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,9 @@
1616
import warnings
1717
from typing import Callable, Dict, Optional, Sequence, Tuple, Union
1818

19-
from google.api_core import grpc_helpers # type: ignore
20-
from google.api_core import operations_v1 # type: ignore
21-
from google.api_core import gapic_v1 # type: ignore
19+
from google.api_core import grpc_helpers
20+
from google.api_core import operations_v1
21+
from google.api_core import gapic_v1
2222
import google.auth # type: ignore
2323
from google.auth import credentials as ga_credentials # type: ignore
2424
from google.auth.transport.grpc import SslCredentials # type: ignore

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,9 @@
1616
import warnings
1717
from typing import Awaitable, Callable, Dict, Optional, Sequence, Tuple, Union
1818

19-
from google.api_core import gapic_v1 # type: ignore
20-
from google.api_core import grpc_helpers_async # type: ignore
21-
from google.api_core import operations_v1 # type: ignore
19+
from google.api_core import gapic_v1
20+
from google.api_core import grpc_helpers_async
21+
from google.api_core import operations_v1
2222
from google.auth import credentials as ga_credentials # type: ignore
2323
from google.auth.transport.grpc import SslCredentials # type: ignore
2424

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

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,26 +72,32 @@ class DiscoverConnectionProfileRequest(proto.Message):
7272
Must be in the format ``projects/*/locations/*``.
7373
connection_profile (google.cloud.datastream_v1alpha1.types.ConnectionProfile):
7474
An ad-hoc ConnectionProfile configuration.
75+
7576
This field is a member of `oneof`_ ``target``.
7677
connection_profile_name (str):
7778
A reference to an existing ConnectionProfile.
79+
7880
This field is a member of `oneof`_ ``target``.
7981
recursive (bool):
8082
Whether to retrieve the full hierarchy of
8183
data objects (TRUE) or only the current level
8284
(FALSE).
85+
8386
This field is a member of `oneof`_ ``depth``.
8487
recursion_depth (int):
8588
The number of hierarchy levels below the
8689
current level to be retrieved.
90+
8791
This field is a member of `oneof`_ ``depth``.
8892
oracle_rdbms (google.cloud.datastream_v1alpha1.types.OracleRdbms):
8993
Oracle RDBMS to enrich with child data
9094
objects and metadata.
95+
9196
This field is a member of `oneof`_ ``data_object``.
9297
mysql_rdbms (google.cloud.datastream_v1alpha1.types.MysqlRdbms):
9398
MySQL RDBMS to enrich with child data objects
9499
and metadata.
100+
95101
This field is a member of `oneof`_ ``data_object``.
96102
"""
97103

@@ -132,9 +138,11 @@ class DiscoverConnectionProfileResponse(proto.Message):
132138
Attributes:
133139
oracle_rdbms (google.cloud.datastream_v1alpha1.types.OracleRdbms):
134140
Enriched Oracle RDBMS object.
141+
135142
This field is a member of `oneof`_ ``data_object``.
136143
mysql_rdbms (google.cloud.datastream_v1alpha1.types.MysqlRdbms):
137144
Enriched MySQL RDBMS object.
145+
138146
This field is a member of `oneof`_ ``data_object``.
139147
"""
140148

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

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -171,9 +171,11 @@ class ForwardSshTunnelConnectivity(proto.Message):
171171
Port for the SSH tunnel, default value is 22.
172172
password (str):
173173
Input only. SSH password.
174+
174175
This field is a member of `oneof`_ ``authentication_method``.
175176
private_key (str):
176177
Input only. SSH private key.
178+
177179
This field is a member of `oneof`_ ``authentication_method``.
178180
"""
179181

@@ -346,25 +348,32 @@ class ConnectionProfile(proto.Message):
346348
Required. Display name.
347349
oracle_profile (google.cloud.datastream_v1alpha1.types.OracleProfile):
348350
Oracle ConnectionProfile configuration.
351+
349352
This field is a member of `oneof`_ ``profile``.
350353
gcs_profile (google.cloud.datastream_v1alpha1.types.GcsProfile):
351354
Cloud Storage ConnectionProfile
352355
configuration.
356+
353357
This field is a member of `oneof`_ ``profile``.
354358
mysql_profile (google.cloud.datastream_v1alpha1.types.MysqlProfile):
355359
MySQL ConnectionProfile configuration.
360+
356361
This field is a member of `oneof`_ ``profile``.
357362
no_connectivity (google.cloud.datastream_v1alpha1.types.NoConnectivitySettings):
358363
No connectivity option chosen.
364+
359365
This field is a member of `oneof`_ ``connectivity``.
360366
static_service_ip_connectivity (google.cloud.datastream_v1alpha1.types.StaticServiceIpConnectivity):
361367
Static Service IP connectivity.
368+
362369
This field is a member of `oneof`_ ``connectivity``.
363370
forward_ssh_connectivity (google.cloud.datastream_v1alpha1.types.ForwardSshTunnelConnectivity):
364371
Forward SSH tunnel connectivity.
372+
365373
This field is a member of `oneof`_ ``connectivity``.
366374
private_connectivity (google.cloud.datastream_v1alpha1.types.PrivateConnectivity):
367375
Private connectivity.
376+
368377
This field is a member of `oneof`_ ``connectivity``.
369378
"""
370379

@@ -611,9 +620,11 @@ class SourceConfig(proto.Message):
611620
identifier.
612621
oracle_source_config (google.cloud.datastream_v1alpha1.types.OracleSourceConfig):
613622
Oracle data source configuration
623+
614624
This field is a member of `oneof`_ ``source_stream_config``.
615625
mysql_source_config (google.cloud.datastream_v1alpha1.types.MysqlSourceConfig):
616626
MySQL data source configuration
627+
617628
This field is a member of `oneof`_ ``source_stream_config``.
618629
"""
619630

@@ -683,9 +694,11 @@ class GcsDestinationConfig(proto.Message):
683694
created.
684695
avro_file_format (google.cloud.datastream_v1alpha1.types.AvroFileFormat):
685696
AVRO file format configuration.
697+
686698
This field is a member of `oneof`_ ``file_format``.
687699
json_file_format (google.cloud.datastream_v1alpha1.types.JsonFileFormat):
688700
JSON file format configuration.
701+
689702
This field is a member of `oneof`_ ``file_format``.
690703
"""
691704

@@ -760,9 +773,11 @@ class Stream(proto.Message):
760773
Automatically backfill objects included in
761774
the stream source configuration. Specific
762775
objects can be excluded.
776+
763777
This field is a member of `oneof`_ ``backfill_strategy``.
764778
backfill_none (google.cloud.datastream_v1alpha1.types.Stream.BackfillNoneStrategy):
765779
Do not automatically backfill any objects.
780+
766781
This field is a member of `oneof`_ ``backfill_strategy``.
767782
errors (Sequence[google.cloud.datastream_v1alpha1.types.Error]):
768783
Output only. Errors on the Stream.
@@ -795,10 +810,12 @@ class BackfillAllStrategy(proto.Message):
795810
oracle_excluded_objects (google.cloud.datastream_v1alpha1.types.OracleRdbms):
796811
Oracle data source objects to avoid
797812
backfilling.
813+
798814
This field is a member of `oneof`_ ``excluded_objects``.
799815
mysql_excluded_objects (google.cloud.datastream_v1alpha1.types.MysqlRdbms):
800816
MySQL data source objects to avoid
801817
backfilling.
818+
802819
This field is a member of `oneof`_ ``excluded_objects``.
803820
"""
804821

0 commit comments

Comments
 (0)