Content-Length: 1074164 | pFad | http://github.com/googleapis/python-datastream/commit/029b5ac9f520cf1e6618c2faefdc4ad9528cf5e9

EF chore: Update gapic-generator-python to v1.8.5 (#161) · googleapis/python-datastream@029b5ac · GitHub
Skip to content
This repository was archived by the owner on Sep 5, 2023. It is now read-only.

Commit 029b5ac

Browse files
gcf-owl-bot[bot]parthea
gcf-owl-bot[bot]
and
parthea
authored
chore: Update gapic-generator-python to v1.8.5 (#161)
* chore: Update gapic-generator-python to v1.8.5 PiperOrigin-RevId: 511892190 Source-Link: googleapis/googleapis@a45d9c0 Source-Link: https://github.com/googleapis/googleapis-gen/commit/1907294b1d8365ea24f8c5f2e059a64124c4ed3b Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMTkwNzI5NGIxZDgzNjVlYTI0ZjhjNWYyZTA1OWE2NDEyNGM0ZWQzYiJ9 * 🦉 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> Co-authored-by: Anthonios Partheniou <partheniou@google.com>
1 parent 9ef7ea6 commit 029b5ac

File tree

8 files changed

+69
-65
lines changed

8 files changed

+69
-65
lines changed

‎google/cloud/datastream_v1/services/datastream/transports/rest.py

Lines changed: 38 additions & 42 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
import dataclasses
1818
import json # type: ignore
1919
import re
20-
from typing import Callable, Dict, List, Optional, Sequence, Tuple, Union
20+
from typing import Any, Callable, Dict, List, Optional, Sequence, Tuple, Union
2121
import warnings
2222

2323
from google.api_core import (
@@ -854,7 +854,7 @@ def pre_get_location(
854854
self,
855855
request: locations_pb2.GetLocationRequest,
856856
metadata: Sequence[Tuple[str, str]],
857-
) -> locations_pb2.Location:
857+
) -> Tuple[locations_pb2.GetLocationRequest, Sequence[Tuple[str, str]]]:
858858
"""Pre-rpc interceptor for get_location
859859
860860
Override in a subclass to manipulate the request or metadata
@@ -863,7 +863,7 @@ def pre_get_location(
863863
return request, metadata
864864

865865
def post_get_location(
866-
self, response: locations_pb2.GetLocationRequest
866+
self, response: locations_pb2.Location
867867
) -> locations_pb2.Location:
868868
"""Post-rpc interceptor for get_location
869869
@@ -877,7 +877,7 @@ def pre_list_locations(
877877
self,
878878
request: locations_pb2.ListLocationsRequest,
879879
metadata: Sequence[Tuple[str, str]],
880-
) -> locations_pb2.ListLocationsResponse:
880+
) -> Tuple[locations_pb2.ListLocationsRequest, Sequence[Tuple[str, str]]]:
881881
"""Pre-rpc interceptor for list_locations
882882
883883
Override in a subclass to manipulate the request or metadata
@@ -886,7 +886,7 @@ def pre_list_locations(
886886
return request, metadata
887887

888888
def post_list_locations(
889-
self, response: locations_pb2.ListLocationsRequest
889+
self, response: locations_pb2.ListLocationsResponse
890890
) -> locations_pb2.ListLocationsResponse:
891891
"""Post-rpc interceptor for list_locations
892892
@@ -900,17 +900,15 @@ def pre_cancel_operation(
900900
self,
901901
request: operations_pb2.CancelOperationRequest,
902902
metadata: Sequence[Tuple[str, str]],
903-
) -> None:
903+
) -> Tuple[operations_pb2.CancelOperationRequest, Sequence[Tuple[str, str]]]:
904904
"""Pre-rpc interceptor for cancel_operation
905905
906906
Override in a subclass to manipulate the request or metadata
907907
before they are sent to the Datastream server.
908908
"""
909909
return request, metadata
910910

911-
def post_cancel_operation(
912-
self, response: operations_pb2.CancelOperationRequest
913-
) -> None:
911+
def post_cancel_operation(self, response: None) -> None:
914912
"""Post-rpc interceptor for cancel_operation
915913
916914
Override in a subclass to manipulate the response
@@ -923,17 +921,15 @@ def pre_delete_operation(
923921
self,
924922
request: operations_pb2.DeleteOperationRequest,
925923
metadata: Sequence[Tuple[str, str]],
926-
) -> None:
924+
) -> Tuple[operations_pb2.DeleteOperationRequest, Sequence[Tuple[str, str]]]:
927925
"""Pre-rpc interceptor for delete_operation
928926
929927
Override in a subclass to manipulate the request or metadata
930928
before they are sent to the Datastream server.
931929
"""
932930
return request, metadata
933931

934-
def post_delete_operation(
935-
self, response: operations_pb2.DeleteOperationRequest
936-
) -> None:
932+
def post_delete_operation(self, response: None) -> None:
937933
"""Post-rpc interceptor for delete_operation
938934
939935
Override in a subclass to manipulate the response
@@ -946,7 +942,7 @@ def pre_get_operation(
946942
self,
947943
request: operations_pb2.GetOperationRequest,
948944
metadata: Sequence[Tuple[str, str]],
949-
) -> operations_pb2.Operation:
945+
) -> Tuple[operations_pb2.GetOperationRequest, Sequence[Tuple[str, str]]]:
950946
"""Pre-rpc interceptor for get_operation
951947
952948
Override in a subclass to manipulate the request or metadata
@@ -955,7 +951,7 @@ def pre_get_operation(
955951
return request, metadata
956952

957953
def post_get_operation(
958-
self, response: operations_pb2.GetOperationRequest
954+
self, response: operations_pb2.Operation
959955
) -> operations_pb2.Operation:
960956
"""Post-rpc interceptor for get_operation
961957
@@ -969,7 +965,7 @@ def pre_list_operations(
969965
self,
970966
request: operations_pb2.ListOperationsRequest,
971967
metadata: Sequence[Tuple[str, str]],
972-
) -> operations_pb2.ListOperationsResponse:
968+
) -> Tuple[operations_pb2.ListOperationsRequest, Sequence[Tuple[str, str]]]:
973969
"""Pre-rpc interceptor for list_operations
974970
975971
Override in a subclass to manipulate the request or metadata
@@ -978,7 +974,7 @@ def pre_list_operations(
978974
return request, metadata
979975

980976
def post_list_operations(
981-
self, response: operations_pb2.ListOperationsRequest
977+
self, response: operations_pb2.ListOperationsResponse
982978
) -> operations_pb2.ListOperationsResponse:
983979
"""Post-rpc interceptor for list_operations
984980
@@ -1143,7 +1139,7 @@ class _CreateConnectionProfile(DatastreamRestStub):
11431139
def __hash__(self):
11441140
return hash("CreateConnectionProfile")
11451141

1146-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {
1142+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {
11471143
"connectionProfileId": "",
11481144
}
11491145

@@ -1245,7 +1241,7 @@ class _CreatePrivateConnection(DatastreamRestStub):
12451241
def __hash__(self):
12461242
return hash("CreatePrivateConnection")
12471243

1248-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {
1244+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {
12491245
"privateConnectionId": "",
12501246
}
12511247

@@ -1347,7 +1343,7 @@ class _CreateRoute(DatastreamRestStub):
13471343
def __hash__(self):
13481344
return hash("CreateRoute")
13491345

1350-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {
1346+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {
13511347
"routeId": "",
13521348
}
13531349

@@ -1445,7 +1441,7 @@ class _CreateStream(DatastreamRestStub):
14451441
def __hash__(self):
14461442
return hash("CreateStream")
14471443

1448-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {
1444+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {
14491445
"streamId": "",
14501446
}
14511447

@@ -1545,7 +1541,7 @@ class _DeleteConnectionProfile(DatastreamRestStub):
15451541
def __hash__(self):
15461542
return hash("DeleteConnectionProfile")
15471543

1548-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
1544+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
15491545

15501546
@classmethod
15511547
def _get_unset_required_fields(cls, message_dict):
@@ -1636,7 +1632,7 @@ class _DeletePrivateConnection(DatastreamRestStub):
16361632
def __hash__(self):
16371633
return hash("DeletePrivateConnection")
16381634

1639-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
1635+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
16401636

16411637
@classmethod
16421638
def _get_unset_required_fields(cls, message_dict):
@@ -1727,7 +1723,7 @@ class _DeleteRoute(DatastreamRestStub):
17271723
def __hash__(self):
17281724
return hash("DeleteRoute")
17291725

1730-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
1726+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
17311727

17321728
@classmethod
17331729
def _get_unset_required_fields(cls, message_dict):
@@ -1814,7 +1810,7 @@ class _DeleteStream(DatastreamRestStub):
18141810
def __hash__(self):
18151811
return hash("DeleteStream")
18161812

1817-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
1813+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
18181814

18191815
@classmethod
18201816
def _get_unset_required_fields(cls, message_dict):
@@ -1903,7 +1899,7 @@ class _DiscoverConnectionProfile(DatastreamRestStub):
19031899
def __hash__(self):
19041900
return hash("DiscoverConnectionProfile")
19051901

1906-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
1902+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
19071903

19081904
@classmethod
19091905
def _get_unset_required_fields(cls, message_dict):
@@ -2003,7 +1999,7 @@ class _FetchStaticIps(DatastreamRestStub):
20031999
def __hash__(self):
20042000
return hash("FetchStaticIps")
20052001

2006-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2002+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
20072003

20082004
@classmethod
20092005
def _get_unset_required_fields(cls, message_dict):
@@ -2095,7 +2091,7 @@ class _GetConnectionProfile(DatastreamRestStub):
20952091
def __hash__(self):
20962092
return hash("GetConnectionProfile")
20972093

2098-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2094+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
20992095

21002096
@classmethod
21012097
def _get_unset_required_fields(cls, message_dict):
@@ -2188,7 +2184,7 @@ class _GetPrivateConnection(DatastreamRestStub):
21882184
def __hash__(self):
21892185
return hash("GetPrivateConnection")
21902186

2191-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2187+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
21922188

21932189
@classmethod
21942190
def _get_unset_required_fields(cls, message_dict):
@@ -2282,7 +2278,7 @@ class _GetRoute(DatastreamRestStub):
22822278
def __hash__(self):
22832279
return hash("GetRoute")
22842280

2285-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2281+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
22862282

22872283
@classmethod
22882284
def _get_unset_required_fields(cls, message_dict):
@@ -2372,7 +2368,7 @@ class _GetStream(DatastreamRestStub):
23722368
def __hash__(self):
23732369
return hash("GetStream")
23742370

2375-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2371+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
23762372

23772373
@classmethod
23782374
def _get_unset_required_fields(cls, message_dict):
@@ -2460,7 +2456,7 @@ class _GetStreamObject(DatastreamRestStub):
24602456
def __hash__(self):
24612457
return hash("GetStreamObject")
24622458

2463-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2459+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
24642460

24652461
@classmethod
24662462
def _get_unset_required_fields(cls, message_dict):
@@ -2552,7 +2548,7 @@ class _ListConnectionProfiles(DatastreamRestStub):
25522548
def __hash__(self):
25532549
return hash("ListConnectionProfiles")
25542550

2555-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2551+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
25562552

25572553
@classmethod
25582554
def _get_unset_required_fields(cls, message_dict):
@@ -2644,7 +2640,7 @@ class _ListPrivateConnections(DatastreamRestStub):
26442640
def __hash__(self):
26452641
return hash("ListPrivateConnections")
26462642

2647-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2643+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
26482644

26492645
@classmethod
26502646
def _get_unset_required_fields(cls, message_dict):
@@ -2736,7 +2732,7 @@ class _ListRoutes(DatastreamRestStub):
27362732
def __hash__(self):
27372733
return hash("ListRoutes")
27382734

2739-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2735+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
27402736

27412737
@classmethod
27422738
def _get_unset_required_fields(cls, message_dict):
@@ -2822,7 +2818,7 @@ class _ListStreamObjects(DatastreamRestStub):
28222818
def __hash__(self):
28232819
return hash("ListStreamObjects")
28242820

2825-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2821+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
28262822

28272823
@classmethod
28282824
def _get_unset_required_fields(cls, message_dict):
@@ -2914,7 +2910,7 @@ class _ListStreams(DatastreamRestStub):
29142910
def __hash__(self):
29152911
return hash("ListStreams")
29162912

2917-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2913+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
29182914

29192915
@classmethod
29202916
def _get_unset_required_fields(cls, message_dict):
@@ -3000,7 +2996,7 @@ class _LookupStreamObject(DatastreamRestStub):
30002996
def __hash__(self):
30012997
return hash("LookupStreamObject")
30022998

3003-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
2999+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
30043000

30053001
@classmethod
30063002
def _get_unset_required_fields(cls, message_dict):
@@ -3102,7 +3098,7 @@ class _StartBackfillJob(DatastreamRestStub):
31023098
def __hash__(self):
31033099
return hash("StartBackfillJob")
31043100

3105-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
3101+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
31063102

31073103
@classmethod
31083104
def _get_unset_required_fields(cls, message_dict):
@@ -3205,7 +3201,7 @@ class _StopBackfillJob(DatastreamRestStub):
32053201
def __hash__(self):
32063202
return hash("StopBackfillJob")
32073203

3208-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
3204+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
32093205

32103206
@classmethod
32113207
def _get_unset_required_fields(cls, message_dict):
@@ -3307,7 +3303,7 @@ class _UpdateConnectionProfile(DatastreamRestStub):
33073303
def __hash__(self):
33083304
return hash("UpdateConnectionProfile")
33093305

3310-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
3306+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
33113307

33123308
@classmethod
33133309
def _get_unset_required_fields(cls, message_dict):
@@ -3405,7 +3401,7 @@ class _UpdateStream(DatastreamRestStub):
34053401
def __hash__(self):
34063402
return hash("UpdateStream")
34073403

3408-
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {}
3404+
__REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {}
34093405

34103406
@classmethod
34113407
def _get_unset_required_fields(cls, message_dict):

‎google/cloud/datastream_v1/types/datastream.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,8 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16+
from __future__ import annotations
17+
1618
from typing import MutableMapping, MutableSequence
1719

1820
from google.protobuf import field_mask_pb2 # type: ignore

‎google/cloud/datastream_v1/types/datastream_resources.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,8 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16+
from __future__ import annotations
17+
1618
from typing import MutableMapping, MutableSequence
1719

1820
from google.protobuf import duration_pb2 # type: ignore

0 commit comments

Comments
 (0)








ApplySandwichStrip

pFad - (p)hone/(F)rame/(a)nonymizer/(d)eclutterfier!      Saves Data!


--- a PPN by Garber Painting Akron. With Image Size Reduction included!

Fetched URL: http://github.com/googleapis/python-datastream/commit/029b5ac9f520cf1e6618c2faefdc4ad9528cf5e9

Alternative Proxies:

Alternative Proxy

pFad Proxy

pFad v3 Proxy

pFad v4 Proxy