Skip to content
This repository has been archived by the owner on Sep 5, 2023. It is now read-only.

Commit

Permalink
fix: remove gRPC send/recv limit; add enums to types/__init__.py (#87)
Browse files Browse the repository at this point in the history
  • Loading branch information
@yoshi-automation
yoshi-automation committed Dec 29, 2020
1 parent 7e91e0f commit e0c40c7
Show file tree
Hide file tree
Showing 21 changed files with 125 additions and 18 deletions.
Empty file removed datacatalog-v1-py.tar.gz
View file
Empty file.
1 change: 0 additions & 1 deletion google/cloud/datacatalog_v1/services/data_catalog/transports/__init__.py
View file
Expand Up @@ -28,7 +28,6 @@
_transport_registry["grpc"] = DataCatalogGrpcTransport
_transport_registry["grpc_asyncio"] = DataCatalogGrpcAsyncIOTransport


__all__ = (
"DataCatalogTransport",
"DataCatalogGrpcTransport",
Expand Down
10 changes: 9 additions & 1 deletion google/cloud/datacatalog_v1/services/data_catalog/transports/grpc.py
View file
Expand Up @@ -151,6 +151,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -169,6 +173,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

self._stubs = {} # type: Dict[str, Callable]
Expand All @@ -195,7 +203,7 @@ def create_channel(
) -> grpc.Channel:
"""Create and return a gRPC channel object.
Args:
address (Optionsl[str]): The host for the channel to use.
address (Optional[str]): The host for the channel to use.
credentials (Optional[~.Credentials]): The
authorization credentials to attach to requests. These
credentials identify this application to the service. If
Expand Down
8 changes: 8 additions & 0 deletions google/cloud/datacatalog_v1/services/data_catalog/transports/grpc_asyncio.py
View file
Expand Up @@ -196,6 +196,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -214,6 +218,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

# Run the base constructor.
Expand Down
12 changes: 10 additions & 2 deletions google/cloud/datacatalog_v1/types/__init__.py
View file
Expand Up @@ -24,12 +24,16 @@
Schema,
ColumnSchema,
)
from .search import SearchCatalogResult
from .search import (
SearchCatalogResult,
SearchResultType,
)
from .table_spec import (
BigQueryTableSpec,
ViewSpec,
TableSpec,
BigQueryDateShardedSpec,
TableSourceType,
)
from .tags import (
Tag,
Expand Down Expand Up @@ -69,20 +73,23 @@
ListTagsResponse,
ListEntriesRequest,
ListEntriesResponse,
EntryType,
)


__all__ = (
"IntegratedSystem",
"SystemTimestamps",
"GcsFilesetSpec",
"GcsFileSpec",
"Schema",
"ColumnSchema",
"SearchCatalogResult",
"SearchResultType",
"BigQueryTableSpec",
"ViewSpec",
"TableSpec",
"BigQueryDateShardedSpec",
"TableSourceType",
"Tag",
"TagField",
"TagTemplate",
Expand Down Expand Up @@ -118,4 +125,5 @@
"ListTagsResponse",
"ListEntriesRequest",
"ListEntriesResponse",
"EntryType",
)
4 changes: 2 additions & 2 deletions google/cloud/datacatalog_v1beta1/__init__.py
View file
Expand Up @@ -103,6 +103,7 @@
"CreateTagTemplateFieldRequest",
"CreateTagTemplateRequest",
"CreateTaxonomyRequest",
"DataCatalogClient",
"DeleteEntryGroupRequest",
"DeleteEntryRequest",
"DeletePolicyTagRequest",
Expand Down Expand Up @@ -139,7 +140,6 @@
"ListTaxonomiesResponse",
"LookupEntryRequest",
"PolicyTag",
"PolicyTagManagerClient",
"PolicyTagManagerSerializationClient",
"RenameTagTemplateFieldRequest",
"Schema",
Expand All @@ -165,5 +165,5 @@
"UpdateTagTemplateRequest",
"UpdateTaxonomyRequest",
"ViewSpec",
"DataCatalogClient",
"PolicyTagManagerClient",
)
1 change: 0 additions & 1 deletion google/cloud/datacatalog_v1beta1/services/data_catalog/transports/__init__.py
View file
Expand Up @@ -28,7 +28,6 @@
_transport_registry["grpc"] = DataCatalogGrpcTransport
_transport_registry["grpc_asyncio"] = DataCatalogGrpcAsyncIOTransport


__all__ = (
"DataCatalogTransport",
"DataCatalogGrpcTransport",
Expand Down
10 changes: 9 additions & 1 deletion google/cloud/datacatalog_v1beta1/services/data_catalog/transports/grpc.py
View file
Expand Up @@ -151,6 +151,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -169,6 +173,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

self._stubs = {} # type: Dict[str, Callable]
Expand All @@ -195,7 +203,7 @@ def create_channel(
) -> grpc.Channel:
"""Create and return a gRPC channel object.
Args:
address (Optionsl[str]): The host for the channel to use.
address (Optional[str]): The host for the channel to use.
credentials (Optional[~.Credentials]): The
authorization credentials to attach to requests. These
credentials identify this application to the service. If
Expand Down
8 changes: 8 additions & 0 deletions google/cloud/datacatalog_v1beta1/services/data_catalog/transports/grpc_asyncio.py
View file
Expand Up @@ -196,6 +196,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -214,6 +218,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

# Run the base constructor.
Expand Down
1 change: 0 additions & 1 deletion google/cloud/datacatalog_v1beta1/services/policy_tag_manager/transports/__init__.py
View file
Expand Up @@ -28,7 +28,6 @@
_transport_registry["grpc"] = PolicyTagManagerGrpcTransport
_transport_registry["grpc_asyncio"] = PolicyTagManagerGrpcAsyncIOTransport


__all__ = (
"PolicyTagManagerTransport",
"PolicyTagManagerGrpcTransport",
Expand Down
10 changes: 9 additions & 1 deletion google/cloud/datacatalog_v1beta1/services/policy_tag_manager/transports/grpc.py
View file
Expand Up @@ -150,6 +150,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -168,6 +172,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

self._stubs = {} # type: Dict[str, Callable]
Expand All @@ -194,7 +202,7 @@ def create_channel(
) -> grpc.Channel:
"""Create and return a gRPC channel object.
Args:
address (Optionsl[str]): The host for the channel to use.
address (Optional[str]): The host for the channel to use.
credentials (Optional[~.Credentials]): The
authorization credentials to attach to requests. These
credentials identify this application to the service. If
Expand Down
8 changes: 8 additions & 0 deletions google/cloud/datacatalog_v1beta1/services/policy_tag_manager/transports/grpc_asyncio.py
View file
Expand Up @@ -195,6 +195,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -213,6 +217,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

# Run the base constructor.
Expand Down
1 change: 0 additions & 1 deletion ...loud/datacatalog_v1beta1/services/policy_tag_manager_serialization/transports/__init__.py
View file
Expand Up @@ -30,7 +30,6 @@
_transport_registry["grpc"] = PolicyTagManagerSerializationGrpcTransport
_transport_registry["grpc_asyncio"] = PolicyTagManagerSerializationGrpcAsyncIOTransport


__all__ = (
"PolicyTagManagerSerializationTransport",
"PolicyTagManagerSerializationGrpcTransport",
Expand Down
10 changes: 9 additions & 1 deletion ...le/cloud/datacatalog_v1beta1/services/policy_tag_manager_serialization/transports/grpc.py
View file
Expand Up @@ -150,6 +150,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -168,6 +172,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

self._stubs = {} # type: Dict[str, Callable]
Expand All @@ -194,7 +202,7 @@ def create_channel(
) -> grpc.Channel:
"""Create and return a gRPC channel object.
Args:
address (Optionsl[str]): The host for the channel to use.
address (Optional[str]): The host for the channel to use.
credentials (Optional[~.Credentials]): The
authorization credentials to attach to requests. These
credentials identify this application to the service. If
Expand Down
8 changes: 8 additions & 0 deletions .../datacatalog_v1beta1/services/policy_tag_manager_serialization/transports/grpc_asyncio.py
View file
Expand Up @@ -195,6 +195,10 @@ def __init__(
ssl_credentials=ssl_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)
self._ssl_channel_credentials = ssl_credentials
else:
Expand All @@ -213,6 +217,10 @@ def __init__(
ssl_credentials=ssl_channel_credentials,
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
options=[
("grpc.max_send_message_length", -1),
("grpc.max_receive_message_length", -1),
],
)

# Run the base constructor.
Expand Down
12 changes: 10 additions & 2 deletions google/cloud/datacatalog_v1beta1/types/__init__.py
View file
Expand Up @@ -24,12 +24,16 @@
Schema,
ColumnSchema,
)
from .search import SearchCatalogResult
from .search import (
SearchCatalogResult,
SearchResultType,
)
from .table_spec import (
BigQueryTableSpec,
ViewSpec,
TableSpec,
BigQueryDateShardedSpec,
TableSourceType,
)
from .tags import (
Tag,
Expand Down Expand Up @@ -69,6 +73,7 @@
ListTagsResponse,
ListEntriesRequest,
ListEntriesResponse,
EntryType,
)
from .policytagmanager import (
Taxonomy,
Expand Down Expand Up @@ -96,18 +101,20 @@
ExportTaxonomiesResponse,
)


__all__ = (
"IntegratedSystem",
"SystemTimestamps",
"GcsFilesetSpec",
"GcsFileSpec",
"Schema",
"ColumnSchema",
"SearchCatalogResult",
"SearchResultType",
"BigQueryTableSpec",
"ViewSpec",
"TableSpec",
"BigQueryDateShardedSpec",
"TableSourceType",
"Tag",
"TagField",
"TagTemplate",
Expand Down Expand Up @@ -143,6 +150,7 @@
"ListTagsResponse",
"ListEntriesRequest",
"ListEntriesResponse",
"EntryType",
"Taxonomy",
"PolicyTag",
"CreateTaxonomyRequest",
Expand Down
7 changes: 3 additions & 4 deletions synth.metadata
View file
Expand Up @@ -4,15 +4,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/python-datacatalog.git",
"sha": "b2c8892d9e900d8b353ef6f035fc7c0f4f75a974"
"sha": "6ca679ec15c6bab726e311b7637d4c8c9c84e508"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
"sha": "53eb2512a55caabcbad1898225080a2a3dfcb6aa",
"internalRef": "346818879"
"sha": "dd372aa22ded7a8ba6f0e03a80e06358a3fa0907",
"internalRef": "347055288"
}
},
{
Expand Down Expand Up @@ -100,7 +100,6 @@
"CONTRIBUTING.rst",
"LICENSE",
"MANIFEST.in",
"datacatalog-v1-py.tar.gz",
"docs/_static/custom.css",
"docs/_templates/layout.html",
"docs/conf.py",
Expand Down

0 comments on commit e0c40c7

Please sign in to comment.