Skip to content

Commit 9e70645

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
chore: use gapic-generator-python 0.51.2 (#29)
- [ ] Regenerate this pull request now. fix: add 'dict' annotation type to 'request' Committer: @busunkim96 PiperOrigin-RevId: 398509016 Source-Link: googleapis/googleapis@b224dfa Source-Link: googleapis/googleapis-gen@63a1db7 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjNhMWRiN2EzOGQ3NGI5NjM5NTkyZjUyMWVkMWRhYWY3Mjk5YWQ5YSJ9
1 parent 781046e commit 9e70645

5 files changed

Lines changed: 72 additions & 72 deletions

File tree

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

Lines changed: 43 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
from distutils import util
1818
import os
1919
import re
20-
from typing import Callable, Dict, Optional, Sequence, Tuple, Type, Union
20+
from typing import Dict, Optional, Sequence, Tuple, Type, Union
2121
import pkg_resources
2222

2323
from google.api_core import client_options as client_options_lib # type: ignore
@@ -413,7 +413,7 @@ def __init__(
413413

414414
def list_connection_profiles(
415415
self,
416-
request: datastream.ListConnectionProfilesRequest = None,
416+
request: Union[datastream.ListConnectionProfilesRequest, dict] = None,
417417
*,
418418
parent: str = None,
419419
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -424,7 +424,7 @@ def list_connection_profiles(
424424
in a project and location.
425425
426426
Args:
427-
request (google.cloud.datastream_v1alpha1.types.ListConnectionProfilesRequest):
427+
request (Union[google.cloud.datastream_v1alpha1.types.ListConnectionProfilesRequest, dict]):
428428
The request object.
429429
parent (str):
430430
Required. The parent that owns the
@@ -491,7 +491,7 @@ def list_connection_profiles(
491491

492492
def get_connection_profile(
493493
self,
494-
request: datastream.GetConnectionProfileRequest = None,
494+
request: Union[datastream.GetConnectionProfileRequest, dict] = None,
495495
*,
496496
name: str = None,
497497
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -502,7 +502,7 @@ def get_connection_profile(
502502
profile.
503503
504504
Args:
505-
request (google.cloud.datastream_v1alpha1.types.GetConnectionProfileRequest):
505+
request (Union[google.cloud.datastream_v1alpha1.types.GetConnectionProfileRequest, dict]):
506506
The request object.
507507
name (str):
508508
Required. The name of the connection
@@ -560,7 +560,7 @@ def get_connection_profile(
560560

561561
def create_connection_profile(
562562
self,
563-
request: datastream.CreateConnectionProfileRequest = None,
563+
request: Union[datastream.CreateConnectionProfileRequest, dict] = None,
564564
*,
565565
parent: str = None,
566566
connection_profile: datastream_resources.ConnectionProfile = None,
@@ -573,7 +573,7 @@ def create_connection_profile(
573573
project and location.
574574
575575
Args:
576-
request (google.cloud.datastream_v1alpha1.types.CreateConnectionProfileRequest):
576+
request (Union[google.cloud.datastream_v1alpha1.types.CreateConnectionProfileRequest, dict]):
577577
The request object.
578578
parent (str):
579579
Required. The parent that owns the
@@ -663,7 +663,7 @@ def create_connection_profile(
663663

664664
def update_connection_profile(
665665
self,
666-
request: datastream.UpdateConnectionProfileRequest = None,
666+
request: Union[datastream.UpdateConnectionProfileRequest, dict] = None,
667667
*,
668668
connection_profile: datastream_resources.ConnectionProfile = None,
669669
update_mask: field_mask_pb2.FieldMask = None,
@@ -675,7 +675,7 @@ def update_connection_profile(
675675
connection profile.
676676
677677
Args:
678-
request (google.cloud.datastream_v1alpha1.types.UpdateConnectionProfileRequest):
678+
request (Union[google.cloud.datastream_v1alpha1.types.UpdateConnectionProfileRequest, dict]):
679679
The request object.
680680
connection_profile (google.cloud.datastream_v1alpha1.types.ConnectionProfile):
681681
Required. The ConnectionProfile to
@@ -763,7 +763,7 @@ def update_connection_profile(
763763

764764
def delete_connection_profile(
765765
self,
766-
request: datastream.DeleteConnectionProfileRequest = None,
766+
request: Union[datastream.DeleteConnectionProfileRequest, dict] = None,
767767
*,
768768
name: str = None,
769769
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -773,7 +773,7 @@ def delete_connection_profile(
773773
r"""Use this method to delete a connection profile..
774774
775775
Args:
776-
request (google.cloud.datastream_v1alpha1.types.DeleteConnectionProfileRequest):
776+
request (Union[google.cloud.datastream_v1alpha1.types.DeleteConnectionProfileRequest, dict]):
777777
The request object.
778778
name (str):
779779
Required. The name of the connection
@@ -856,7 +856,7 @@ def delete_connection_profile(
856856

857857
def discover_connection_profile(
858858
self,
859-
request: datastream.DiscoverConnectionProfileRequest = None,
859+
request: Union[datastream.DiscoverConnectionProfileRequest, dict] = None,
860860
*,
861861
retry: retries.Retry = gapic_v1.method.DEFAULT,
862862
timeout: float = None,
@@ -869,7 +869,7 @@ def discover_connection_profile(
869869
that's optionally supplied in the request.
870870
871871
Args:
872-
request (google.cloud.datastream_v1alpha1.types.DiscoverConnectionProfileRequest):
872+
request (Union[google.cloud.datastream_v1alpha1.types.DiscoverConnectionProfileRequest, dict]):
873873
The request object. Request message for 'discover'
874874
ConnectionProfile request.
875875
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -910,7 +910,7 @@ def discover_connection_profile(
910910

911911
def list_streams(
912912
self,
913-
request: datastream.ListStreamsRequest = None,
913+
request: Union[datastream.ListStreamsRequest, dict] = None,
914914
*,
915915
parent: str = None,
916916
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -921,7 +921,7 @@ def list_streams(
921921
location.
922922
923923
Args:
924-
request (google.cloud.datastream_v1alpha1.types.ListStreamsRequest):
924+
request (Union[google.cloud.datastream_v1alpha1.types.ListStreamsRequest, dict]):
925925
The request object.
926926
parent (str):
927927
Required. The parent that owns the
@@ -988,7 +988,7 @@ def list_streams(
988988

989989
def get_stream(
990990
self,
991-
request: datastream.GetStreamRequest = None,
991+
request: Union[datastream.GetStreamRequest, dict] = None,
992992
*,
993993
name: str = None,
994994
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -998,7 +998,7 @@ def get_stream(
998998
r"""Use this method to get details about a stream.
999999
10001000
Args:
1001-
request (google.cloud.datastream_v1alpha1.types.GetStreamRequest):
1001+
request (Union[google.cloud.datastream_v1alpha1.types.GetStreamRequest, dict]):
10021002
The request object.
10031003
name (str):
10041004
Required. The name of the stream
@@ -1056,7 +1056,7 @@ def get_stream(
10561056

10571057
def create_stream(
10581058
self,
1059-
request: datastream.CreateStreamRequest = None,
1059+
request: Union[datastream.CreateStreamRequest, dict] = None,
10601060
*,
10611061
parent: str = None,
10621062
stream: datastream_resources.Stream = None,
@@ -1068,7 +1068,7 @@ def create_stream(
10681068
r"""Use this method to create a stream.
10691069
10701070
Args:
1071-
request (google.cloud.datastream_v1alpha1.types.CreateStreamRequest):
1071+
request (Union[google.cloud.datastream_v1alpha1.types.CreateStreamRequest, dict]):
10721072
The request object.
10731073
parent (str):
10741074
Required. The parent that owns the
@@ -1154,7 +1154,7 @@ def create_stream(
11541154

11551155
def update_stream(
11561156
self,
1157-
request: datastream.UpdateStreamRequest = None,
1157+
request: Union[datastream.UpdateStreamRequest, dict] = None,
11581158
*,
11591159
stream: datastream_resources.Stream = None,
11601160
update_mask: field_mask_pb2.FieldMask = None,
@@ -1166,7 +1166,7 @@ def update_stream(
11661166
stream.
11671167
11681168
Args:
1169-
request (google.cloud.datastream_v1alpha1.types.UpdateStreamRequest):
1169+
request (Union[google.cloud.datastream_v1alpha1.types.UpdateStreamRequest, dict]):
11701170
The request object.
11711171
stream (google.cloud.datastream_v1alpha1.types.Stream):
11721172
Required. The stream resource to
@@ -1251,7 +1251,7 @@ def update_stream(
12511251

12521252
def delete_stream(
12531253
self,
1254-
request: datastream.DeleteStreamRequest = None,
1254+
request: Union[datastream.DeleteStreamRequest, dict] = None,
12551255
*,
12561256
name: str = None,
12571257
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1261,7 +1261,7 @@ def delete_stream(
12611261
r"""Use this method to delete a stream.
12621262
12631263
Args:
1264-
request (google.cloud.datastream_v1alpha1.types.DeleteStreamRequest):
1264+
request (Union[google.cloud.datastream_v1alpha1.types.DeleteStreamRequest, dict]):
12651265
The request object.
12661266
name (str):
12671267
Required. The name of the stream
@@ -1342,7 +1342,7 @@ def delete_stream(
13421342

13431343
def fetch_errors(
13441344
self,
1345-
request: datastream.FetchErrorsRequest = None,
1345+
request: Union[datastream.FetchErrorsRequest, dict] = None,
13461346
*,
13471347
retry: retries.Retry = gapic_v1.method.DEFAULT,
13481348
timeout: float = None,
@@ -1352,7 +1352,7 @@ def fetch_errors(
13521352
stream.
13531353
13541354
Args:
1355-
request (google.cloud.datastream_v1alpha1.types.FetchErrorsRequest):
1355+
request (Union[google.cloud.datastream_v1alpha1.types.FetchErrorsRequest, dict]):
13561356
The request object. Request message for 'FetchErrors'
13571357
request.
13581358
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -1404,7 +1404,7 @@ def fetch_errors(
14041404

14051405
def fetch_static_ips(
14061406
self,
1407-
request: datastream.FetchStaticIpsRequest = None,
1407+
request: Union[datastream.FetchStaticIpsRequest, dict] = None,
14081408
*,
14091409
name: str = None,
14101410
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1417,7 +1417,7 @@ def fetch_static_ips(
14171417
optionally supplied in the request.
14181418
14191419
Args:
1420-
request (google.cloud.datastream_v1alpha1.types.FetchStaticIpsRequest):
1420+
request (Union[google.cloud.datastream_v1alpha1.types.FetchStaticIpsRequest, dict]):
14211421
The request object. Request message for 'FetchStaticIps'
14221422
request.
14231423
name (str):
@@ -1487,7 +1487,7 @@ def fetch_static_ips(
14871487

14881488
def create_private_connection(
14891489
self,
1490-
request: datastream.CreatePrivateConnectionRequest = None,
1490+
request: Union[datastream.CreatePrivateConnectionRequest, dict] = None,
14911491
*,
14921492
parent: str = None,
14931493
private_connection: datastream_resources.PrivateConnection = None,
@@ -1500,7 +1500,7 @@ def create_private_connection(
15001500
configuration.
15011501
15021502
Args:
1503-
request (google.cloud.datastream_v1alpha1.types.CreatePrivateConnectionRequest):
1503+
request (Union[google.cloud.datastream_v1alpha1.types.CreatePrivateConnectionRequest, dict]):
15041504
The request object.
15051505
parent (str):
15061506
Required. The parent that owns the
@@ -1590,7 +1590,7 @@ def create_private_connection(
15901590

15911591
def get_private_connection(
15921592
self,
1593-
request: datastream.GetPrivateConnectionRequest = None,
1593+
request: Union[datastream.GetPrivateConnectionRequest, dict] = None,
15941594
*,
15951595
name: str = None,
15961596
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1601,7 +1601,7 @@ def get_private_connection(
16011601
connectivity configuration.
16021602
16031603
Args:
1604-
request (google.cloud.datastream_v1alpha1.types.GetPrivateConnectionRequest):
1604+
request (Union[google.cloud.datastream_v1alpha1.types.GetPrivateConnectionRequest, dict]):
16051605
The request object.
16061606
name (str):
16071607
Required. The name of the private
@@ -1663,7 +1663,7 @@ def get_private_connection(
16631663

16641664
def list_private_connections(
16651665
self,
1666-
request: datastream.ListPrivateConnectionsRequest = None,
1666+
request: Union[datastream.ListPrivateConnectionsRequest, dict] = None,
16671667
*,
16681668
parent: str = None,
16691669
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1674,7 +1674,7 @@ def list_private_connections(
16741674
configurations in a project and location.
16751675
16761676
Args:
1677-
request (google.cloud.datastream_v1alpha1.types.ListPrivateConnectionsRequest):
1677+
request (Union[google.cloud.datastream_v1alpha1.types.ListPrivateConnectionsRequest, dict]):
16781678
The request object.
16791679
parent (str):
16801680
Required. The parent that owns the
@@ -1742,7 +1742,7 @@ def list_private_connections(
17421742

17431743
def delete_private_connection(
17441744
self,
1745-
request: datastream.DeletePrivateConnectionRequest = None,
1745+
request: Union[datastream.DeletePrivateConnectionRequest, dict] = None,
17461746
*,
17471747
name: str = None,
17481748
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1753,7 +1753,7 @@ def delete_private_connection(
17531753
configuration.
17541754
17551755
Args:
1756-
request (google.cloud.datastream_v1alpha1.types.DeletePrivateConnectionRequest):
1756+
request (Union[google.cloud.datastream_v1alpha1.types.DeletePrivateConnectionRequest, dict]):
17571757
The request object.
17581758
name (str):
17591759
Required. The name of the private
@@ -1836,7 +1836,7 @@ def delete_private_connection(
18361836

18371837
def create_route(
18381838
self,
1839-
request: datastream.CreateRouteRequest = None,
1839+
request: Union[datastream.CreateRouteRequest, dict] = None,
18401840
*,
18411841
parent: str = None,
18421842
route: datastream_resources.Route = None,
@@ -1849,7 +1849,7 @@ def create_route(
18491849
connectivity in a project and location.
18501850
18511851
Args:
1852-
request (google.cloud.datastream_v1alpha1.types.CreateRouteRequest):
1852+
request (Union[google.cloud.datastream_v1alpha1.types.CreateRouteRequest, dict]):
18531853
The request object. route creation request
18541854
parent (str):
18551855
Required. The parent that owns the
@@ -1936,7 +1936,7 @@ def create_route(
19361936

19371937
def get_route(
19381938
self,
1939-
request: datastream.GetRouteRequest = None,
1939+
request: Union[datastream.GetRouteRequest, dict] = None,
19401940
*,
19411941
name: str = None,
19421942
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1946,7 +1946,7 @@ def get_route(
19461946
r"""Use this method to get details about a route.
19471947
19481948
Args:
1949-
request (google.cloud.datastream_v1alpha1.types.GetRouteRequest):
1949+
request (Union[google.cloud.datastream_v1alpha1.types.GetRouteRequest, dict]):
19501950
The request object. route get request
19511951
name (str):
19521952
Required. The name of the Route
@@ -2008,7 +2008,7 @@ def get_route(
20082008

20092009
def list_routes(
20102010
self,
2011-
request: datastream.ListRoutesRequest = None,
2011+
request: Union[datastream.ListRoutesRequest, dict] = None,
20122012
*,
20132013
parent: str = None,
20142014
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -2019,7 +2019,7 @@ def list_routes(
20192019
connectivity in a project and location.
20202020
20212021
Args:
2022-
request (google.cloud.datastream_v1alpha1.types.ListRoutesRequest):
2022+
request (Union[google.cloud.datastream_v1alpha1.types.ListRoutesRequest, dict]):
20232023
The request object. route list request
20242024
parent (str):
20252025
Required. The parent that owns the
@@ -2087,7 +2087,7 @@ def list_routes(
20872087

20882088
def delete_route(
20892089
self,
2090-
request: datastream.DeleteRouteRequest = None,
2090+
request: Union[datastream.DeleteRouteRequest, dict] = None,
20912091
*,
20922092
name: str = None,
20932093
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -2097,7 +2097,7 @@ def delete_route(
20972097
r"""Use this method to delete a route.
20982098
20992099
Args:
2100-
request (google.cloud.datastream_v1alpha1.types.DeleteRouteRequest):
2100+
request (Union[google.cloud.datastream_v1alpha1.types.DeleteRouteRequest, dict]):
21012101
The request object. route deletion request
21022102
name (str):
21032103
Required. The name of the Route

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ def __init__(
120120
**scopes_kwargs, quota_project_id=quota_project_id
121121
)
122122

123-
# If the credentials is service account credentials, then always try to use self signed JWT.
123+
# If the credentials are service account credentials, then always try to use self signed JWT.
124124
if (
125125
always_use_jwt_access
126126
and isinstance(credentials, service_account.Credentials)

0 commit comments

Comments
 (0)