diff --git a/.github/.OwlBot.lock.yaml b/.github/.OwlBot.lock.yaml index 894fb6b..b8edda5 100644 --- a/.github/.OwlBot.lock.yaml +++ b/.github/.OwlBot.lock.yaml @@ -13,4 +13,4 @@ # limitations under the License. docker: image: gcr.io/cloud-devrel-public-resources/owlbot-python:latest - digest: sha256:f62c53736eccb0c4934a3ea9316e0d57696bb49c1a7c86c726e9bb8a2f87dadf + digest: sha256:2e247c7bf5154df7f98cce087a20ca7605e236340c7d6d1a14447e5c06791bd6 diff --git a/.kokoro/requirements.in b/.kokoro/requirements.in index cbd7e77..ec867d9 100644 --- a/.kokoro/requirements.in +++ b/.kokoro/requirements.in @@ -1,10 +1,10 @@ gcp-docuploader -gcp-releasetool +gcp-releasetool>=1.10.5 # required for compatibility with cryptography>=39.x importlib-metadata typing-extensions twine wheel setuptools -nox +nox>=2022.11.21 # required to remove dependency on py charset-normalizer<3 click<8.1.0 diff --git a/.kokoro/requirements.txt b/.kokoro/requirements.txt index 096e480..66a2172 100644 --- a/.kokoro/requirements.txt +++ b/.kokoro/requirements.txt @@ -1,6 +1,6 @@ # -# This file is autogenerated by pip-compile with python 3.10 -# To update, run: +# This file is autogenerated by pip-compile with Python 3.9 +# by the following command: # # pip-compile --allow-unsafe --generate-hashes requirements.in # @@ -154,9 +154,9 @@ gcp-docuploader==0.6.4 \ --hash=sha256:01486419e24633af78fd0167db74a2763974765ee8078ca6eb6964d0ebd388af \ --hash=sha256:70861190c123d907b3b067da896265ead2eeb9263969d6955c9e0bb091b5ccbf # via -r requirements.in -gcp-releasetool==1.10.0 \ - --hash=sha256:72a38ca91b59c24f7e699e9227c90cbe4dd71b789383cb0164b088abae294c83 \ - --hash=sha256:8c7c99320208383d4bb2b808c6880eb7a81424afe7cdba3c8d84b25f4f0e097d +gcp-releasetool==1.10.5 \ + --hash=sha256:174b7b102d704b254f2a26a3eda2c684fd3543320ec239baf771542a2e58e109 \ + --hash=sha256:e29d29927fe2ca493105a82958c6873bb2b90d503acac56be2c229e74de0eec9 # via -r requirements.in google-api-core==2.10.2 \ --hash=sha256:10c06f7739fe57781f87523375e8e1a3a4674bf6392cd6131a3222182b971320 \ @@ -335,9 +335,9 @@ more-itertools==9.0.0 \ --hash=sha256:250e83d7e81d0c87ca6bd942e6aeab8cc9daa6096d12c5308f3f92fa5e5c1f41 \ --hash=sha256:5a6257e40878ef0520b1803990e3e22303a41b5714006c32a3fd8304b26ea1ab # via jaraco-classes -nox==2022.8.7 \ - --hash=sha256:1b894940551dc5c389f9271d197ca5d655d40bdc6ccf93ed6880e4042760a34b \ - --hash=sha256:96cca88779e08282a699d672258ec01eb7c792d35bbbf538c723172bce23212c +nox==2022.11.21 \ + --hash=sha256:0e41a990e290e274cb205a976c4c97ee3c5234441a8132c8c3fd9ea3c22149eb \ + --hash=sha256:e21c31de0711d1274ca585a2c5fde36b1aa962005ba8e9322bf5eeed16dcd684 # via -r requirements.in packaging==21.3 \ --hash=sha256:dd47c42927d89ab911e606518907cc2d3a1f38bbd026385970643f9c5b8ecfeb \ @@ -380,10 +380,6 @@ protobuf==3.20.3 \ # gcp-docuploader # gcp-releasetool # google-api-core -py==1.11.0 \ - --hash=sha256:51c75c4126074b472f746a24399ad32f6053d1b34b68d2fa41e558e6f4a98719 \ - --hash=sha256:607c53218732647dff4acdfcd50cb62615cedf612e72d1724fb1a0cc6405b378 - # via nox pyasn1==0.4.8 \ --hash=sha256:39c7e2ec30515947ff4e87fb6f456dfc6e84857d34be479c9d4a4ba4bf46aa5d \ --hash=sha256:aef77c9fb94a3ac588e87841208bdec464471d9871bd5050a287cc9a475cd0ba diff --git a/.release-please-manifest.json b/.release-please-manifest.json index dd8fde7..e20d7e8 100644 --- a/.release-please-manifest.json +++ b/.release-please-manifest.json @@ -1,3 +1,3 @@ { - ".": "1.5.0" + ".": "1.5.1" } diff --git a/CHANGELOG.md b/CHANGELOG.md index a58971a..76e8258 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,12 @@ # Changelog +## [1.5.1](https://github.com/googleapis/python-datastream/compare/v1.5.0...v1.5.1) (2023-03-23) + + +### Documentation + +* Fix formatting of request arg in docstring ([#165](https://github.com/googleapis/python-datastream/issues/165)) ([e44614b](https://github.com/googleapis/python-datastream/commit/e44614bcc93cce5ef8219166bb76769ecd51f8a5)) + ## [1.5.0](https://github.com/googleapis/python-datastream/compare/v1.4.1...v1.5.0) (2023-02-17) diff --git a/datastream-v1alpha1-py.tar.gz b/datastream-v1alpha1-py.tar.gz index 4495c3c..18329e8 100644 Binary files a/datastream-v1alpha1-py.tar.gz and b/datastream-v1alpha1-py.tar.gz differ diff --git a/google/cloud/datastream/gapic_version.py b/google/cloud/datastream/gapic_version.py index 997edc1..69ff013 100644 --- a/google/cloud/datastream/gapic_version.py +++ b/google/cloud/datastream/gapic_version.py @@ -13,4 +13,4 @@ # See the License for the specific language governing permissions and # limitations under the License. # -__version__ = "1.5.0" # {x-release-please-version} +__version__ = "1.5.1" # {x-release-please-version} diff --git a/google/cloud/datastream_v1/gapic_version.py b/google/cloud/datastream_v1/gapic_version.py index 997edc1..69ff013 100644 --- a/google/cloud/datastream_v1/gapic_version.py +++ b/google/cloud/datastream_v1/gapic_version.py @@ -13,4 +13,4 @@ # See the License for the specific language governing permissions and # limitations under the License. # -__version__ = "1.5.0" # {x-release-please-version} +__version__ = "1.5.1" # {x-release-please-version} diff --git a/google/cloud/datastream_v1/services/datastream/async_client.py b/google/cloud/datastream_v1/services/datastream/async_client.py index 74bebf4..f71e003 100644 --- a/google/cloud/datastream_v1/services/datastream/async_client.py +++ b/google/cloud/datastream_v1/services/datastream/async_client.py @@ -1114,8 +1114,7 @@ async def sample_get_stream(): Args: request (Optional[Union[google.cloud.datastream_v1.types.GetStreamRequest, dict]]): - The request object. Request message for getting a - stream. + The request object. Request message for getting a stream. name (:class:`str`): Required. The name of the stream resource to get. @@ -1731,7 +1730,8 @@ async def sample_lookup_stream_object(): Args: request (Optional[Union[google.cloud.datastream_v1.types.LookupStreamObjectRequest, dict]]): The request object. Request for looking up a specific - stream object by its source object identifier. + stream object by its source object + identifier. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1813,8 +1813,8 @@ async def sample_list_stream_objects(): Args: request (Optional[Union[google.cloud.datastream_v1.types.ListStreamObjectsRequest, dict]]): - The request object. Request for listing all objects for - a specific stream. + The request object. Request for listing all objects for a + specific stream. parent (:class:`str`): Required. The parent stream that owns the collection of objects. @@ -1929,7 +1929,8 @@ async def sample_start_backfill_job(): Args: request (Optional[Union[google.cloud.datastream_v1.types.StartBackfillJobRequest, dict]]): The request object. Request for manually initiating a - backfill job for a specific stream object. + backfill job for a specific stream + object. object_ (:class:`str`): Required. The name of the stream object resource to start a backfill job @@ -2034,7 +2035,8 @@ async def sample_stop_backfill_job(): Args: request (Optional[Union[google.cloud.datastream_v1.types.StopBackfillJobRequest, dict]]): The request object. Request for manually stopping a - running backfill job for a specific stream object. + running backfill job for a specific + stream object. object_ (:class:`str`): Required. The name of the stream object resource to stop the backfill job diff --git a/google/cloud/datastream_v1/services/datastream/client.py b/google/cloud/datastream_v1/services/datastream/client.py index 89d11e6..1968b68 100644 --- a/google/cloud/datastream_v1/services/datastream/client.py +++ b/google/cloud/datastream_v1/services/datastream/client.py @@ -1453,8 +1453,7 @@ def sample_get_stream(): Args: request (Union[google.cloud.datastream_v1.types.GetStreamRequest, dict]): - The request object. Request message for getting a - stream. + The request object. Request message for getting a stream. name (str): Required. The name of the stream resource to get. @@ -2070,7 +2069,8 @@ def sample_lookup_stream_object(): Args: request (Union[google.cloud.datastream_v1.types.LookupStreamObjectRequest, dict]): The request object. Request for looking up a specific - stream object by its source object identifier. + stream object by its source object + identifier. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2153,8 +2153,8 @@ def sample_list_stream_objects(): Args: request (Union[google.cloud.datastream_v1.types.ListStreamObjectsRequest, dict]): - The request object. Request for listing all objects for - a specific stream. + The request object. Request for listing all objects for a + specific stream. parent (str): Required. The parent stream that owns the collection of objects. @@ -2269,7 +2269,8 @@ def sample_start_backfill_job(): Args: request (Union[google.cloud.datastream_v1.types.StartBackfillJobRequest, dict]): The request object. Request for manually initiating a - backfill job for a specific stream object. + backfill job for a specific stream + object. object_ (str): Required. The name of the stream object resource to start a backfill job @@ -2374,7 +2375,8 @@ def sample_stop_backfill_job(): Args: request (Union[google.cloud.datastream_v1.types.StopBackfillJobRequest, dict]): The request object. Request for manually stopping a - running backfill job for a specific stream object. + running backfill job for a specific + stream object. object_ (str): Required. The name of the stream object resource to stop the backfill job diff --git a/google/cloud/datastream_v1/services/datastream/transports/rest.py b/google/cloud/datastream_v1/services/datastream/transports/rest.py index ad2551f..f463083 100644 --- a/google/cloud/datastream_v1/services/datastream/transports/rest.py +++ b/google/cloud/datastream_v1/services/datastream/transports/rest.py @@ -17,7 +17,7 @@ import dataclasses import json # type: ignore import re -from typing import Callable, Dict, List, Optional, Sequence, Tuple, Union +from typing import Any, Callable, Dict, List, Optional, Sequence, Tuple, Union import warnings from google.api_core import ( @@ -854,7 +854,7 @@ def pre_get_location( self, request: locations_pb2.GetLocationRequest, metadata: Sequence[Tuple[str, str]], - ) -> locations_pb2.Location: + ) -> Tuple[locations_pb2.GetLocationRequest, Sequence[Tuple[str, str]]]: """Pre-rpc interceptor for get_location Override in a subclass to manipulate the request or metadata @@ -863,7 +863,7 @@ def pre_get_location( return request, metadata def post_get_location( - self, response: locations_pb2.GetLocationRequest + self, response: locations_pb2.Location ) -> locations_pb2.Location: """Post-rpc interceptor for get_location @@ -877,7 +877,7 @@ def pre_list_locations( self, request: locations_pb2.ListLocationsRequest, metadata: Sequence[Tuple[str, str]], - ) -> locations_pb2.ListLocationsResponse: + ) -> Tuple[locations_pb2.ListLocationsRequest, Sequence[Tuple[str, str]]]: """Pre-rpc interceptor for list_locations Override in a subclass to manipulate the request or metadata @@ -886,7 +886,7 @@ def pre_list_locations( return request, metadata def post_list_locations( - self, response: locations_pb2.ListLocationsRequest + self, response: locations_pb2.ListLocationsResponse ) -> locations_pb2.ListLocationsResponse: """Post-rpc interceptor for list_locations @@ -900,7 +900,7 @@ def pre_cancel_operation( self, request: operations_pb2.CancelOperationRequest, metadata: Sequence[Tuple[str, str]], - ) -> None: + ) -> Tuple[operations_pb2.CancelOperationRequest, Sequence[Tuple[str, str]]]: """Pre-rpc interceptor for cancel_operation Override in a subclass to manipulate the request or metadata @@ -908,9 +908,7 @@ def pre_cancel_operation( """ return request, metadata - def post_cancel_operation( - self, response: operations_pb2.CancelOperationRequest - ) -> None: + def post_cancel_operation(self, response: None) -> None: """Post-rpc interceptor for cancel_operation Override in a subclass to manipulate the response @@ -923,7 +921,7 @@ def pre_delete_operation( self, request: operations_pb2.DeleteOperationRequest, metadata: Sequence[Tuple[str, str]], - ) -> None: + ) -> Tuple[operations_pb2.DeleteOperationRequest, Sequence[Tuple[str, str]]]: """Pre-rpc interceptor for delete_operation Override in a subclass to manipulate the request or metadata @@ -931,9 +929,7 @@ def pre_delete_operation( """ return request, metadata - def post_delete_operation( - self, response: operations_pb2.DeleteOperationRequest - ) -> None: + def post_delete_operation(self, response: None) -> None: """Post-rpc interceptor for delete_operation Override in a subclass to manipulate the response @@ -946,7 +942,7 @@ def pre_get_operation( self, request: operations_pb2.GetOperationRequest, metadata: Sequence[Tuple[str, str]], - ) -> operations_pb2.Operation: + ) -> Tuple[operations_pb2.GetOperationRequest, Sequence[Tuple[str, str]]]: """Pre-rpc interceptor for get_operation Override in a subclass to manipulate the request or metadata @@ -955,7 +951,7 @@ def pre_get_operation( return request, metadata def post_get_operation( - self, response: operations_pb2.GetOperationRequest + self, response: operations_pb2.Operation ) -> operations_pb2.Operation: """Post-rpc interceptor for get_operation @@ -969,7 +965,7 @@ def pre_list_operations( self, request: operations_pb2.ListOperationsRequest, metadata: Sequence[Tuple[str, str]], - ) -> operations_pb2.ListOperationsResponse: + ) -> Tuple[operations_pb2.ListOperationsRequest, Sequence[Tuple[str, str]]]: """Pre-rpc interceptor for list_operations Override in a subclass to manipulate the request or metadata @@ -978,7 +974,7 @@ def pre_list_operations( return request, metadata def post_list_operations( - self, response: operations_pb2.ListOperationsRequest + self, response: operations_pb2.ListOperationsResponse ) -> operations_pb2.ListOperationsResponse: """Post-rpc interceptor for list_operations @@ -1143,7 +1139,7 @@ class _CreateConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("CreateConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = { + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = { "connectionProfileId": "", } @@ -1169,7 +1165,6 @@ def __call__( request (~.datastream.CreateConnectionProfileRequest): The request object. Request message for creating a connection profile. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1245,7 +1240,7 @@ class _CreatePrivateConnection(DatastreamRestStub): def __hash__(self): return hash("CreatePrivateConnection") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = { + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = { "privateConnectionId": "", } @@ -1271,7 +1266,6 @@ def __call__( request (~.datastream.CreatePrivateConnectionRequest): The request object. Request for creating a private connection. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1347,7 +1341,7 @@ class _CreateRoute(DatastreamRestStub): def __hash__(self): return hash("CreateRoute") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = { + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = { "routeId": "", } @@ -1445,7 +1439,7 @@ class _CreateStream(DatastreamRestStub): def __hash__(self): return hash("CreateStream") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = { + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = { "streamId": "", } @@ -1471,7 +1465,6 @@ def __call__( request (~.datastream.CreateStreamRequest): The request object. Request message for creating a stream. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1545,7 +1538,7 @@ class _DeleteConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("DeleteConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1569,7 +1562,6 @@ def __call__( request (~.datastream.DeleteConnectionProfileRequest): The request object. Request message for deleting a connection profile. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1636,7 +1628,7 @@ class _DeletePrivateConnection(DatastreamRestStub): def __hash__(self): return hash("DeletePrivateConnection") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1660,7 +1652,6 @@ def __call__( request (~.datastream.DeletePrivateConnectionRequest): The request object. Request to delete a private connection. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1727,7 +1718,7 @@ class _DeleteRoute(DatastreamRestStub): def __hash__(self): return hash("DeleteRoute") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1814,7 +1805,7 @@ class _DeleteStream(DatastreamRestStub): def __hash__(self): return hash("DeleteStream") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1838,7 +1829,6 @@ def __call__( request (~.datastream.DeleteStreamRequest): The request object. Request message for deleting a stream. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1903,7 +1893,7 @@ class _DiscoverConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("DiscoverConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1928,7 +1918,6 @@ def __call__( request (~.datastream.DiscoverConnectionProfileRequest): The request object. Request message for 'discover' ConnectionProfile request. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2003,7 +1992,7 @@ class _FetchStaticIps(DatastreamRestStub): def __hash__(self): return hash("FetchStaticIps") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2027,7 +2016,6 @@ def __call__( request (~.datastream.FetchStaticIpsRequest): The request object. Request message for 'FetchStaticIps' request. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2095,7 +2083,7 @@ class _GetConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("GetConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2119,7 +2107,6 @@ def __call__( request (~.datastream.GetConnectionProfileRequest): The request object. Request message for getting a connection profile. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2188,7 +2175,7 @@ class _GetPrivateConnection(DatastreamRestStub): def __hash__(self): return hash("GetPrivateConnection") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2212,7 +2199,6 @@ def __call__( request (~.datastream.GetPrivateConnectionRequest): The request object. Request to get a private connection configuration. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2282,7 +2268,7 @@ class _GetRoute(DatastreamRestStub): def __hash__(self): return hash("GetRoute") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2372,7 +2358,7 @@ class _GetStream(DatastreamRestStub): def __hash__(self): return hash("GetStream") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2460,7 +2446,7 @@ class _GetStreamObject(DatastreamRestStub): def __hash__(self): return hash("GetStreamObject") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2484,7 +2470,6 @@ def __call__( request (~.datastream.GetStreamObjectRequest): The request object. Request for fetching a specific stream object. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2552,7 +2537,7 @@ class _ListConnectionProfiles(DatastreamRestStub): def __hash__(self): return hash("ListConnectionProfiles") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2576,7 +2561,6 @@ def __call__( request (~.datastream.ListConnectionProfilesRequest): The request object. Request message for listing connection profiles. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2644,7 +2628,7 @@ class _ListPrivateConnections(DatastreamRestStub): def __hash__(self): return hash("ListPrivateConnections") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2668,7 +2652,6 @@ def __call__( request (~.datastream.ListPrivateConnectionsRequest): The request object. Request for listing private connections. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2736,7 +2719,7 @@ class _ListRoutes(DatastreamRestStub): def __hash__(self): return hash("ListRoutes") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2822,7 +2805,7 @@ class _ListStreamObjects(DatastreamRestStub): def __hash__(self): return hash("ListStreamObjects") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2846,7 +2829,6 @@ def __call__( request (~.datastream.ListStreamObjectsRequest): The request object. Request for listing all objects for a specific stream. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -2914,7 +2896,7 @@ class _ListStreams(DatastreamRestStub): def __hash__(self): return hash("ListStreams") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -3000,7 +2982,7 @@ class _LookupStreamObject(DatastreamRestStub): def __hash__(self): return hash("LookupStreamObject") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -3025,7 +3007,6 @@ def __call__( The request object. Request for looking up a specific stream object by its source object identifier. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -3102,7 +3083,7 @@ class _StartBackfillJob(DatastreamRestStub): def __hash__(self): return hash("StartBackfillJob") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -3127,7 +3108,6 @@ def __call__( The request object. Request for manually initiating a backfill job for a specific stream object. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -3205,7 +3185,7 @@ class _StopBackfillJob(DatastreamRestStub): def __hash__(self): return hash("StopBackfillJob") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -3230,7 +3210,6 @@ def __call__( The request object. Request for manually stopping a running backfill job for a specific stream object. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -3307,7 +3286,7 @@ class _UpdateConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("UpdateConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -3405,7 +3384,7 @@ class _UpdateStream(DatastreamRestStub): def __hash__(self): return hash("UpdateStream") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -3429,7 +3408,6 @@ def __call__( request (~.datastream.UpdateStreamRequest): The request object. Request message for updating a stream. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. diff --git a/google/cloud/datastream_v1/types/datastream.py b/google/cloud/datastream_v1/types/datastream.py index 60c5f0e..59890f4 100644 --- a/google/cloud/datastream_v1/types/datastream.py +++ b/google/cloud/datastream_v1/types/datastream.py @@ -13,6 +13,8 @@ # See the License for the specific language governing permissions and # limitations under the License. # +from __future__ import annotations + from typing import MutableMapping, MutableSequence from google.protobuf import field_mask_pb2 # type: ignore diff --git a/google/cloud/datastream_v1/types/datastream_resources.py b/google/cloud/datastream_v1/types/datastream_resources.py index b16f52d..a49ab02 100644 --- a/google/cloud/datastream_v1/types/datastream_resources.py +++ b/google/cloud/datastream_v1/types/datastream_resources.py @@ -13,6 +13,8 @@ # See the License for the specific language governing permissions and # limitations under the License. # +from __future__ import annotations + from typing import MutableMapping, MutableSequence from google.protobuf import duration_pb2 # type: ignore diff --git a/google/cloud/datastream_v1alpha1/gapic_version.py b/google/cloud/datastream_v1alpha1/gapic_version.py index 997edc1..69ff013 100644 --- a/google/cloud/datastream_v1alpha1/gapic_version.py +++ b/google/cloud/datastream_v1alpha1/gapic_version.py @@ -13,4 +13,4 @@ # See the License for the specific language governing permissions and # limitations under the License. # -__version__ = "1.5.0" # {x-release-please-version} +__version__ = "1.5.1" # {x-release-please-version} diff --git a/google/cloud/datastream_v1alpha1/services/datastream/transports/rest.py b/google/cloud/datastream_v1alpha1/services/datastream/transports/rest.py index cde6f2c..0a9c352 100644 --- a/google/cloud/datastream_v1alpha1/services/datastream/transports/rest.py +++ b/google/cloud/datastream_v1alpha1/services/datastream/transports/rest.py @@ -17,7 +17,7 @@ import dataclasses import json # type: ignore import re -from typing import Callable, Dict, List, Optional, Sequence, Tuple, Union +from typing import Any, Callable, Dict, List, Optional, Sequence, Tuple, Union import warnings from google.api_core import ( @@ -877,7 +877,7 @@ class _CreateConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("CreateConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = { + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = { "connectionProfileId": "", } @@ -977,7 +977,7 @@ class _CreatePrivateConnection(DatastreamRestStub): def __hash__(self): return hash("CreatePrivateConnection") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = { + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = { "privateConnectionId": "", } @@ -1077,7 +1077,7 @@ class _CreateRoute(DatastreamRestStub): def __hash__(self): return hash("CreateRoute") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = { + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = { "routeId": "", } @@ -1175,7 +1175,7 @@ class _CreateStream(DatastreamRestStub): def __hash__(self): return hash("CreateStream") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = { + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = { "streamId": "", } @@ -1273,7 +1273,7 @@ class _DeleteConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("DeleteConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1362,7 +1362,7 @@ class _DeletePrivateConnection(DatastreamRestStub): def __hash__(self): return hash("DeletePrivateConnection") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1451,7 +1451,7 @@ class _DeleteRoute(DatastreamRestStub): def __hash__(self): return hash("DeleteRoute") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1538,7 +1538,7 @@ class _DeleteStream(DatastreamRestStub): def __hash__(self): return hash("DeleteStream") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1625,7 +1625,7 @@ class _DiscoverConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("DiscoverConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1650,7 +1650,6 @@ def __call__( request (~.datastream.DiscoverConnectionProfileRequest): The request object. Request message for 'discover' ConnectionProfile request. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1739,7 +1738,6 @@ def __call__( request (~.datastream.FetchErrorsRequest): The request object. Request message for 'FetchErrors' request. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1812,7 +1810,7 @@ class _FetchStaticIps(DatastreamRestStub): def __hash__(self): return hash("FetchStaticIps") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1836,7 +1834,6 @@ def __call__( request (~.datastream.FetchStaticIpsRequest): The request object. Request message for 'FetchStaticIps' request. - retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. timeout (float): The timeout for this request. @@ -1904,7 +1901,7 @@ class _GetConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("GetConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -1992,7 +1989,7 @@ class _GetPrivateConnection(DatastreamRestStub): def __hash__(self): return hash("GetPrivateConnection") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2084,7 +2081,7 @@ class _GetRoute(DatastreamRestStub): def __hash__(self): return hash("GetRoute") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2174,7 +2171,7 @@ class _GetStream(DatastreamRestStub): def __hash__(self): return hash("GetStream") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2260,7 +2257,7 @@ class _ListConnectionProfiles(DatastreamRestStub): def __hash__(self): return hash("ListConnectionProfiles") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2348,7 +2345,7 @@ class _ListPrivateConnections(DatastreamRestStub): def __hash__(self): return hash("ListPrivateConnections") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2436,7 +2433,7 @@ class _ListRoutes(DatastreamRestStub): def __hash__(self): return hash("ListRoutes") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2522,7 +2519,7 @@ class _ListStreams(DatastreamRestStub): def __hash__(self): return hash("ListStreams") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2608,7 +2605,7 @@ class _UpdateConnectionProfile(DatastreamRestStub): def __hash__(self): return hash("UpdateConnectionProfile") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): @@ -2706,7 +2703,7 @@ class _UpdateStream(DatastreamRestStub): def __hash__(self): return hash("UpdateStream") - __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, str] = {} + __REQUIRED_FIELDS_DEFAULT_VALUES: Dict[str, Any] = {} @classmethod def _get_unset_required_fields(cls, message_dict): diff --git a/google/cloud/datastream_v1alpha1/types/datastream.py b/google/cloud/datastream_v1alpha1/types/datastream.py index 709240e..9e34b57 100644 --- a/google/cloud/datastream_v1alpha1/types/datastream.py +++ b/google/cloud/datastream_v1alpha1/types/datastream.py @@ -13,6 +13,8 @@ # See the License for the specific language governing permissions and # limitations under the License. # +from __future__ import annotations + from typing import MutableMapping, MutableSequence from google.protobuf import field_mask_pb2 # type: ignore diff --git a/google/cloud/datastream_v1alpha1/types/datastream_resources.py b/google/cloud/datastream_v1alpha1/types/datastream_resources.py index 7c3f858..943d1a8 100644 --- a/google/cloud/datastream_v1alpha1/types/datastream_resources.py +++ b/google/cloud/datastream_v1alpha1/types/datastream_resources.py @@ -13,6 +13,8 @@ # See the License for the specific language governing permissions and # limitations under the License. # +from __future__ import annotations + from typing import MutableMapping, MutableSequence from google.protobuf import duration_pb2 # type: ignore diff --git a/samples/generated_samples/snippet_metadata_google.cloud.datastream.v1.json b/samples/generated_samples/snippet_metadata_google.cloud.datastream.v1.json index 2803723..dd58d51 100644 --- a/samples/generated_samples/snippet_metadata_google.cloud.datastream.v1.json +++ b/samples/generated_samples/snippet_metadata_google.cloud.datastream.v1.json @@ -8,7 +8,7 @@ ], "language": "PYTHON", "name": "google-cloud-datastream", - "version": "1.5.0" + "version": "1.5.1" }, "snippets": [ { diff --git a/samples/generated_samples/snippet_metadata_google.cloud.datastream.v1alpha1.json b/samples/generated_samples/snippet_metadata_google.cloud.datastream.v1alpha1.json index 9f36141..afccdda 100644 --- a/samples/generated_samples/snippet_metadata_google.cloud.datastream.v1alpha1.json +++ b/samples/generated_samples/snippet_metadata_google.cloud.datastream.v1alpha1.json @@ -8,7 +8,7 @@ ], "language": "PYTHON", "name": "google-cloud-datastream", - "version": "1.5.0" + "version": "1.5.1" }, "snippets": [ { diff --git a/setup.py b/setup.py index 1e90b8f..79a0767 100644 --- a/setup.py +++ b/setup.py @@ -40,7 +40,7 @@ "proto-plus >= 1.22.0, <2.0.0dev", "proto-plus >= 1.22.2, <2.0.0dev; python_version>='3.11'", "protobuf>=3.19.5,<5.0.0dev,!=3.20.0,!=3.20.1,!=4.21.0,!=4.21.1,!=4.21.2,!=4.21.3,!=4.21.4,!=4.21.5", - "grpc-google-iam-v1 >= 0.12.4, < 1.0.0dev", + "grpc-google-iam-v1 >= 0.12.4, <1.0.0dev", ] url = "https://github.com/googleapis/python-datastream"