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

Commit

Permalink
feat: add support for entries associated with Spanner and CloudBigTab…
Browse files Browse the repository at this point in the history 
…le (#475)

* feat: add support for entries associated with Spanner and ClougBigTable
feat: expand SearchCatalogResponse with totalSize
feat: modify documentation for FQN support
feat: extend ImportApiRequest with jobId parameter

PiperOrigin-RevId: 536127089

Source-Link: googleapis/googleapis@208fb58

Source-Link: googleapis/googleapis-gen@df299c5
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZGYyOTljNTg4OGFiMGY1NWYxZGFkNjM5MThhYzg4YjJiMTViYTRlMiJ9

* 🦉 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>
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] and gcf-owl-bot[bot] committed May 29, 2023
1 parent aa73f9f commit c057e0d
Show file tree
Hide file tree
Showing 13 changed files with 217 additions and 211 deletions.
6 changes: 6 additions & 0 deletions google/cloud/datacatalog/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,8 @@
from google.cloud.datacatalog_v1.types.data_source import DataSource, StorageProperties
from google.cloud.datacatalog_v1.types.datacatalog import (
BusinessContext,
CloudBigtableInstanceSpec,
CloudBigtableSystemSpec,
Contacts,
CreateEntryGroupRequest,
CreateEntryRequest,
Expand Down Expand Up @@ -89,6 +91,7 @@
RoutineSpec,
SearchCatalogRequest,
SearchCatalogResponse,
ServiceSpec,
SqlDatabaseSystemSpec,
StarEntryRequest,
StarEntryResponse,
Expand Down Expand Up @@ -181,6 +184,8 @@
"DataSource",
"StorageProperties",
"BusinessContext",
"CloudBigtableInstanceSpec",
"CloudBigtableSystemSpec",
"Contacts",
"CreateEntryGroupRequest",
"CreateEntryRequest",
Expand Down Expand Up @@ -222,6 +227,7 @@
"RoutineSpec",
"SearchCatalogRequest",
"SearchCatalogResponse",
"ServiceSpec",
"SqlDatabaseSystemSpec",
"StarEntryRequest",
"StarEntryResponse",
Expand Down
6 changes: 6 additions & 0 deletions google/cloud/datacatalog_v1/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,8 @@
from .types.data_source import DataSource, StorageProperties
from .types.datacatalog import (
BusinessContext,
CloudBigtableInstanceSpec,
CloudBigtableSystemSpec,
Contacts,
CreateEntryGroupRequest,
CreateEntryRequest,
Expand Down Expand Up @@ -78,6 +80,7 @@
RoutineSpec,
SearchCatalogRequest,
SearchCatalogResponse,
ServiceSpec,
SqlDatabaseSystemSpec,
StarEntryRequest,
StarEntryResponse,
Expand Down Expand Up @@ -147,6 +150,8 @@
"BigQueryRoutineSpec",
"BigQueryTableSpec",
"BusinessContext",
"CloudBigtableInstanceSpec",
"CloudBigtableSystemSpec",
"CloudSqlBigQueryConnectionSpec",
"ColumnSchema",
"CommonUsageStats",
Expand Down Expand Up @@ -231,6 +236,7 @@
"SearchResultType",
"SerializedPolicyTag",
"SerializedTaxonomy",
"ServiceSpec",
"SqlDatabaseSystemSpec",
"StarEntryRequest",
"StarEntryResponse",
Expand Down
99 changes: 9 additions & 90 deletions google/cloud/datacatalog_v1/services/data_catalog/async_client.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -371,16 +371,7 @@ async def sample_search_catalog():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.search_catalog,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down Expand Up @@ -661,16 +652,7 @@ async def sample_get_entry_group():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.get_entry_group,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down Expand Up @@ -998,16 +980,7 @@ async def sample_list_entry_groups():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.list_entry_groups,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down Expand Up @@ -1541,16 +1514,7 @@ async def sample_get_entry():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.get_entry,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down Expand Up @@ -1641,16 +1605,7 @@ async def sample_lookup_entry():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.lookup_entry,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down Expand Up @@ -1755,16 +1710,7 @@ async def sample_list_entries():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.list_entries,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down Expand Up @@ -3554,16 +3500,7 @@ async def sample_list_tags():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.list_tags,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down Expand Up @@ -4262,16 +4199,7 @@ async def sample_get_iam_policy():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.get_iam_policy,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down Expand Up @@ -4473,16 +4401,7 @@ async def sample_import_entries():
# and friendly error handling.
rpc = gapic_v1.method_async.wrap_method(
self._client._transport.import_entries,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=DEFAULT_CLIENT_INFO,
)

Expand Down
99 changes: 9 additions & 90 deletions google/cloud/datacatalog_v1/services/data_catalog/transports/base.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -128,16 +128,7 @@ def _prep_wrapped_messages(self, client_info):
self._wrapped_methods = {
self.search_catalog: gapic_v1.method.wrap_method(
self.search_catalog,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
self.create_entry_group: gapic_v1.method.wrap_method(
Expand All @@ -147,16 +138,7 @@ def _prep_wrapped_messages(self, client_info):
),
self.get_entry_group: gapic_v1.method.wrap_method(
self.get_entry_group,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
self.update_entry_group: gapic_v1.method.wrap_method(
Expand All @@ -171,16 +153,7 @@ def _prep_wrapped_messages(self, client_info):
),
self.list_entry_groups: gapic_v1.method.wrap_method(
self.list_entry_groups,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
self.create_entry: gapic_v1.method.wrap_method(
Expand All @@ -200,44 +173,17 @@ def _prep_wrapped_messages(self, client_info):
),
self.get_entry: gapic_v1.method.wrap_method(
self.get_entry,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
self.lookup_entry: gapic_v1.method.wrap_method(
self.lookup_entry,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
self.list_entries: gapic_v1.method.wrap_method(
self.list_entries,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
self.modify_entry_overview: gapic_v1.method.wrap_method(
Expand Down Expand Up @@ -312,16 +258,7 @@ def _prep_wrapped_messages(self, client_info):
),
self.list_tags: gapic_v1.method.wrap_method(
self.list_tags,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
self.reconcile_tags: gapic_v1.method.wrap_method(
Expand All @@ -346,16 +283,7 @@ def _prep_wrapped_messages(self, client_info):
),
self.get_iam_policy: gapic_v1.method.wrap_method(
self.get_iam_policy,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
self.test_iam_permissions: gapic_v1.method.wrap_method(
Expand All @@ -365,16 +293,7 @@ def _prep_wrapped_messages(self, client_info):
),
self.import_entries: gapic_v1.method.wrap_method(
self.import_entries,
default_retry=retries.Retry(
initial=0.1,
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
core_exceptions.ServiceUnavailable,
),
deadline=60.0,
),
default_timeout=60.0,
default_timeout=None,
client_info=client_info,
),
}
Expand Down

0 comments on commit c057e0d

Please sign in to comment.