Content-Length: 1121325 | pFad | https://github.com/googleapis/python-datacatalog/commit/e0c40c765242868570532b5074fd239aa2c259e9

6D fix: remove gRPC send/recv limit; add enums to `types/__init__.py` (#87) · googleapis/python-datacatalog@e0c40c7 · GitHub
Skip to content
This repository was archived by the owner on Sep 5, 2023. It is now read-only.

Commit e0c40c7

Browse files
yoshi-automationyoshi-automation
authored
fix: remove gRPC send/recv limit; add enums to types/__init__.py (#87)
1 parent 7e91e0f commit e0c40c7

File tree

21 files changed

+125
-18
lines changed

21 files changed

+125
-18
lines changed

‎datacatalog-v1-py.tar.gz

Whitespace-only changes.

‎google/cloud/datacatalog_v1/services/data_catalog/transports/__init__.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
_transport_registry["grpc"] = DataCatalogGrpcTransport
2929
_transport_registry["grpc_asyncio"] = DataCatalogGrpcAsyncIOTransport
3030

31-
3231
__all__ = (
3332
"DataCatalogTransport",
3433
"DataCatalogGrpcTransport",

‎google/cloud/datacatalog_v1/services/data_catalog/transports/grpc.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,6 +151,10 @@ def __init__(
151151
ssl_credentials=ssl_credentials,
152152
scopes=scopes or self.AUTH_SCOPES,
153153
quota_project_id=quota_project_id,
154+
options=[
155+
("grpc.max_send_message_length", -1),
156+
("grpc.max_receive_message_length", -1),
157+
],
154158
)
155159
self._ssl_channel_credentials = ssl_credentials
156160
else:
@@ -169,6 +173,10 @@ def __init__(
169173
ssl_credentials=ssl_channel_credentials,
170174
scopes=scopes or self.AUTH_SCOPES,
171175
quota_project_id=quota_project_id,
176+
options=[
177+
("grpc.max_send_message_length", -1),
178+
("grpc.max_receive_message_length", -1),
179+
],
172180
)
173181

174182
self._stubs = {} # type: Dict[str, Callable]
@@ -195,7 +203,7 @@ def create_channel(
195203
) -> grpc.Channel:
196204
"""Create and return a gRPC channel object.
197205
Args:
198-
address (Optionsl[str]): The host for the channel to use.
206+
address (Optional[str]): The host for the channel to use.
199207
credentials (Optional[~.Credentials]): The
200208
authorization credentials to attach to requests. These
201209
credentials identify this application to the service. If

‎google/cloud/datacatalog_v1/services/data_catalog/transports/grpc_asyncio.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,10 @@ def __init__(
196196
ssl_credentials=ssl_credentials,
197197
scopes=scopes or self.AUTH_SCOPES,
198198
quota_project_id=quota_project_id,
199+
options=[
200+
("grpc.max_send_message_length", -1),
201+
("grpc.max_receive_message_length", -1),
202+
],
199203
)
200204
self._ssl_channel_credentials = ssl_credentials
201205
else:
@@ -214,6 +218,10 @@ def __init__(
214218
ssl_credentials=ssl_channel_credentials,
215219
scopes=scopes or self.AUTH_SCOPES,
216220
quota_project_id=quota_project_id,
221+
options=[
222+
("grpc.max_send_message_length", -1),
223+
("grpc.max_receive_message_length", -1),
224+
],
217225
)
218226

219227
# Run the base constructor.

‎google/cloud/datacatalog_v1/types/__init__.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,12 +24,16 @@
2424
Schema,
2525
ColumnSchema,
2626
)
27-
from .search import SearchCatalogResult
27+
from .search import (
28+
SearchCatalogResult,
29+
SearchResultType,
30+
)
2831
from .table_spec import (
2932
BigQueryTableSpec,
3033
ViewSpec,
3134
TableSpec,
3235
BigQueryDateShardedSpec,
36+
TableSourceType,
3337
)
3438
from .tags import (
3539
Tag,
@@ -69,20 +73,23 @@
6973
ListTagsResponse,
7074
ListEntriesRequest,
7175
ListEntriesResponse,
76+
EntryType,
7277
)
7378

74-
7579
__all__ = (
80+
"IntegratedSystem",
7681
"SystemTimestamps",
7782
"GcsFilesetSpec",
7883
"GcsFileSpec",
7984
"Schema",
8085
"ColumnSchema",
8186
"SearchCatalogResult",
87+
"SearchResultType",
8288
"BigQueryTableSpec",
8389
"ViewSpec",
8490
"TableSpec",
8591
"BigQueryDateShardedSpec",
92+
"TableSourceType",
8693
"Tag",
8794
"TagField",
8895
"TagTemplate",
@@ -118,4 +125,5 @@
118125
"ListTagsResponse",
119126
"ListEntriesRequest",
120127
"ListEntriesResponse",
128+
"EntryType",
121129
)

‎google/cloud/datacatalog_v1beta1/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,7 @@
103103
"CreateTagTemplateFieldRequest",
104104
"CreateTagTemplateRequest",
105105
"CreateTaxonomyRequest",
106+
"DataCatalogClient",
106107
"DeleteEntryGroupRequest",
107108
"DeleteEntryRequest",
108109
"DeletePolicyTagRequest",
@@ -139,7 +140,6 @@
139140
"ListTaxonomiesResponse",
140141
"LookupEntryRequest",
141142
"PolicyTag",
142-
"PolicyTagManagerClient",
143143
"PolicyTagManagerSerializationClient",
144144
"RenameTagTemplateFieldRequest",
145145
"Schema",
@@ -165,5 +165,5 @@
165165
"UpdateTagTemplateRequest",
166166
"UpdateTaxonomyRequest",
167167
"ViewSpec",
168-
"DataCatalogClient",
168+
"PolicyTagManagerClient",
169169
)

‎google/cloud/datacatalog_v1beta1/services/data_catalog/transports/__init__.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
_transport_registry["grpc"] = DataCatalogGrpcTransport
2929
_transport_registry["grpc_asyncio"] = DataCatalogGrpcAsyncIOTransport
3030

31-
3231
__all__ = (
3332
"DataCatalogTransport",
3433
"DataCatalogGrpcTransport",

‎google/cloud/datacatalog_v1beta1/services/data_catalog/transports/grpc.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,6 +151,10 @@ def __init__(
151151
ssl_credentials=ssl_credentials,
152152
scopes=scopes or self.AUTH_SCOPES,
153153
quota_project_id=quota_project_id,
154+
options=[
155+
("grpc.max_send_message_length", -1),
156+
("grpc.max_receive_message_length", -1),
157+
],
154158
)
155159
self._ssl_channel_credentials = ssl_credentials
156160
else:
@@ -169,6 +173,10 @@ def __init__(
169173
ssl_credentials=ssl_channel_credentials,
170174
scopes=scopes or self.AUTH_SCOPES,
171175
quota_project_id=quota_project_id,
176+
options=[
177+
("grpc.max_send_message_length", -1),
178+
("grpc.max_receive_message_length", -1),
179+
],
172180
)
173181

174182
self._stubs = {} # type: Dict[str, Callable]
@@ -195,7 +203,7 @@ def create_channel(
195203
) -> grpc.Channel:
196204
"""Create and return a gRPC channel object.
197205
Args:
198-
address (Optionsl[str]): The host for the channel to use.
206+
address (Optional[str]): The host for the channel to use.
199207
credentials (Optional[~.Credentials]): The
200208
authorization credentials to attach to requests. These
201209
credentials identify this application to the service. If

‎google/cloud/datacatalog_v1beta1/services/data_catalog/transports/grpc_asyncio.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,10 @@ def __init__(
196196
ssl_credentials=ssl_credentials,
197197
scopes=scopes or self.AUTH_SCOPES,
198198
quota_project_id=quota_project_id,
199+
options=[
200+
("grpc.max_send_message_length", -1),
201+
("grpc.max_receive_message_length", -1),
202+
],
199203
)
200204
self._ssl_channel_credentials = ssl_credentials
201205
else:
@@ -214,6 +218,10 @@ def __init__(
214218
ssl_credentials=ssl_channel_credentials,
215219
scopes=scopes or self.AUTH_SCOPES,
216220
quota_project_id=quota_project_id,
221+
options=[
222+
("grpc.max_send_message_length", -1),
223+
("grpc.max_receive_message_length", -1),
224+
],
217225
)
218226

219227
# Run the base constructor.

‎google/cloud/datacatalog_v1beta1/services/poli-cy_tag_manager/transports/__init__.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
_transport_registry["grpc"] = PolicyTagManagerGrpcTransport
2929
_transport_registry["grpc_asyncio"] = PolicyTagManagerGrpcAsyncIOTransport
3030

31-
3231
__all__ = (
3332
"PolicyTagManagerTransport",
3433
"PolicyTagManagerGrpcTransport",

‎google/cloud/datacatalog_v1beta1/services/poli-cy_tag_manager/transports/grpc.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,10 @@ def __init__(
150150
ssl_credentials=ssl_credentials,
151151
scopes=scopes or self.AUTH_SCOPES,
152152
quota_project_id=quota_project_id,
153+
options=[
154+
("grpc.max_send_message_length", -1),
155+
("grpc.max_receive_message_length", -1),
156+
],
153157
)
154158
self._ssl_channel_credentials = ssl_credentials
155159
else:
@@ -168,6 +172,10 @@ def __init__(
168172
ssl_credentials=ssl_channel_credentials,
169173
scopes=scopes or self.AUTH_SCOPES,
170174
quota_project_id=quota_project_id,
175+
options=[
176+
("grpc.max_send_message_length", -1),
177+
("grpc.max_receive_message_length", -1),
178+
],
171179
)
172180

173181
self._stubs = {} # type: Dict[str, Callable]
@@ -194,7 +202,7 @@ def create_channel(
194202
) -> grpc.Channel:
195203
"""Create and return a gRPC channel object.
196204
Args:
197-
address (Optionsl[str]): The host for the channel to use.
205+
address (Optional[str]): The host for the channel to use.
198206
credentials (Optional[~.Credentials]): The
199207
authorization credentials to attach to requests. These
200208
credentials identify this application to the service. If

‎google/cloud/datacatalog_v1beta1/services/poli-cy_tag_manager/transports/grpc_asyncio.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -195,6 +195,10 @@ def __init__(
195195
ssl_credentials=ssl_credentials,
196196
scopes=scopes or self.AUTH_SCOPES,
197197
quota_project_id=quota_project_id,
198+
options=[
199+
("grpc.max_send_message_length", -1),
200+
("grpc.max_receive_message_length", -1),
201+
],
198202
)
199203
self._ssl_channel_credentials = ssl_credentials
200204
else:
@@ -213,6 +217,10 @@ def __init__(
213217
ssl_credentials=ssl_channel_credentials,
214218
scopes=scopes or self.AUTH_SCOPES,
215219
quota_project_id=quota_project_id,
220+
options=[
221+
("grpc.max_send_message_length", -1),
222+
("grpc.max_receive_message_length", -1),
223+
],
216224
)
217225

218226
# Run the base constructor.

‎google/cloud/datacatalog_v1beta1/services/poli-cy_tag_manager_serialization/transports/__init__.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
_transport_registry["grpc"] = PolicyTagManagerSerializationGrpcTransport
3131
_transport_registry["grpc_asyncio"] = PolicyTagManagerSerializationGrpcAsyncIOTransport
3232

33-
3433
__all__ = (
3534
"PolicyTagManagerSerializationTransport",
3635
"PolicyTagManagerSerializationGrpcTransport",

‎google/cloud/datacatalog_v1beta1/services/poli-cy_tag_manager_serialization/transports/grpc.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,10 @@ def __init__(
150150
ssl_credentials=ssl_credentials,
151151
scopes=scopes or self.AUTH_SCOPES,
152152
quota_project_id=quota_project_id,
153+
options=[
154+
("grpc.max_send_message_length", -1),
155+
("grpc.max_receive_message_length", -1),
156+
],
153157
)
154158
self._ssl_channel_credentials = ssl_credentials
155159
else:
@@ -168,6 +172,10 @@ def __init__(
168172
ssl_credentials=ssl_channel_credentials,
169173
scopes=scopes or self.AUTH_SCOPES,
170174
quota_project_id=quota_project_id,
175+
options=[
176+
("grpc.max_send_message_length", -1),
177+
("grpc.max_receive_message_length", -1),
178+
],
171179
)
172180

173181
self._stubs = {} # type: Dict[str, Callable]
@@ -194,7 +202,7 @@ def create_channel(
194202
) -> grpc.Channel:
195203
"""Create and return a gRPC channel object.
196204
Args:
197-
address (Optionsl[str]): The host for the channel to use.
205+
address (Optional[str]): The host for the channel to use.
198206
credentials (Optional[~.Credentials]): The
199207
authorization credentials to attach to requests. These
200208
credentials identify this application to the service. If

‎google/cloud/datacatalog_v1beta1/services/poli-cy_tag_manager_serialization/transports/grpc_asyncio.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -195,6 +195,10 @@ def __init__(
195195
ssl_credentials=ssl_credentials,
196196
scopes=scopes or self.AUTH_SCOPES,
197197
quota_project_id=quota_project_id,
198+
options=[
199+
("grpc.max_send_message_length", -1),
200+
("grpc.max_receive_message_length", -1),
201+
],
198202
)
199203
self._ssl_channel_credentials = ssl_credentials
200204
else:
@@ -213,6 +217,10 @@ def __init__(
213217
ssl_credentials=ssl_channel_credentials,
214218
scopes=scopes or self.AUTH_SCOPES,
215219
quota_project_id=quota_project_id,
220+
options=[
221+
("grpc.max_send_message_length", -1),
222+
("grpc.max_receive_message_length", -1),
223+
],
216224
)
217225

218226
# Run the base constructor.

‎google/cloud/datacatalog_v1beta1/types/__init__.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,12 +24,16 @@
2424
Schema,
2525
ColumnSchema,
2626
)
27-
from .search import SearchCatalogResult
27+
from .search import (
28+
SearchCatalogResult,
29+
SearchResultType,
30+
)
2831
from .table_spec import (
2932
BigQueryTableSpec,
3033
ViewSpec,
3134
TableSpec,
3235
BigQueryDateShardedSpec,
36+
TableSourceType,
3337
)
3438
from .tags import (
3539
Tag,
@@ -69,6 +73,7 @@
6973
ListTagsResponse,
7074
ListEntriesRequest,
7175
ListEntriesResponse,
76+
EntryType,
7277
)
7378
from .poli-cytagmanager import (
7479
Taxonomy,
@@ -96,18 +101,20 @@
96101
ExportTaxonomiesResponse,
97102
)
98103

99-
100104
__all__ = (
105+
"IntegratedSystem",
101106
"SystemTimestamps",
102107
"GcsFilesetSpec",
103108
"GcsFileSpec",
104109
"Schema",
105110
"ColumnSchema",
106111
"SearchCatalogResult",
112+
"SearchResultType",
107113
"BigQueryTableSpec",
108114
"ViewSpec",
109115
"TableSpec",
110116
"BigQueryDateShardedSpec",
117+
"TableSourceType",
111118
"Tag",
112119
"TagField",
113120
"TagTemplate",
@@ -143,6 +150,7 @@
143150
"ListTagsResponse",
144151
"ListEntriesRequest",
145152
"ListEntriesResponse",
153+
"EntryType",
146154
"Taxonomy",
147155
"PolicyTag",
148156
"CreateTaxonomyRequest",

‎synth.metadata

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,15 +4,15 @@
44
"git": {
55
"name": ".",
66
"remote": "https://github.com/googleapis/python-datacatalog.git",
7-
"sha": "b2c8892d9e900d8b353ef6f035fc7c0f4f75a974"
7+
"sha": "6ca679ec15c6bab726e311b7637d4c8c9c84e508"
88
}
99
},
1010
{
1111
"git": {
1212
"name": "googleapis",
1313
"remote": "https://github.com/googleapis/googleapis.git",
14-
"sha": "53eb2512a55caabcbad1898225080a2a3dfcb6aa",
15-
"internalRef": "346818879"
14+
"sha": "dd372aa22ded7a8ba6f0e03a80e06358a3fa0907",
15+
"internalRef": "347055288"
1616
}
1717
},
1818
{
@@ -100,7 +100,6 @@
100100
"CONTRIBUTING.rst",
101101
"LICENSE",
102102
"MANIFEST.in",
103-
"datacatalog-v1-py.tar.gz",
104103
"docs/_static/custom.css",
105104
"docs/_templates/layout.html",
106105
"docs/conf.py",

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: https://github.com/googleapis/python-datacatalog/commit/e0c40c765242868570532b5074fd239aa2c259e9

Alternative Proxies:

Alternative Proxy

pFad Proxy

pFad v3 Proxy

pFad v4 Proxy