Skip to content
Permalink
Browse files
chore: use gapic-generator-python 0.51.2 (#312)
- [ ] Regenerate this pull request now.

fix: add 'dict' annotation type to 'request'

Committer: @busunkim96
PiperOrigin-RevId: 398509016

Source-Link: googleapis/googleapis@b224dfa

Source-Link: https://github.com/googleapis/googleapis-gen/commit/63a1db7a38d74b9639592f521ed1daaf7299ad9a
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjNhMWRiN2EzOGQ3NGI5NjM5NTkyZjUyMWVkMWRhYWY3Mjk5YWQ5YSJ9
  • Loading branch information
gcf-owl-bot[bot] committed Sep 24, 2021
1 parent 66c09c0 commit a7780805d7350855fccdcf2aefa596851ee83923
Showing with 74 additions and 94 deletions.
  1. +7 −7 google/cloud/bigquery_storage_v1/services/big_query_read/client.py
  2. +1 −1 google/cloud/bigquery_storage_v1/services/big_query_read/transports/base.py
  3. +3 −3 google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc.py
  4. +3 −3 google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc_asyncio.py
  5. +11 −21 google/cloud/bigquery_storage_v1/services/big_query_write/client.py
  6. +1 −1 google/cloud/bigquery_storage_v1/services/big_query_write/transports/base.py
  7. +3 −3 google/cloud/bigquery_storage_v1/services/big_query_write/transports/grpc.py
  8. +3 −3 google/cloud/bigquery_storage_v1/services/big_query_write/transports/grpc_asyncio.py
  9. +7 −7 google/cloud/bigquery_storage_v1beta2/services/big_query_read/client.py
  10. +1 −1 google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/base.py
  11. +3 −3 google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc.py
  12. +3 −3 google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc_asyncio.py
  13. +11 −21 google/cloud/bigquery_storage_v1beta2/services/big_query_write/client.py
  14. +1 −1 google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/base.py
  15. +3 −3 google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/grpc.py
  16. +3 −3 google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/grpc_asyncio.py
  17. +10 −10 scripts/fixup_bigquery_storage_v1_keywords.py
@@ -17,7 +17,7 @@
from distutils import util
import os
import re
from typing import Callable, Dict, Optional, Iterable, Sequence, Tuple, Type, Union
from typing import Dict, Optional, Iterable, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core import client_options as client_options_lib # type: ignore
@@ -389,7 +389,7 @@ def __init__(

def create_read_session(
self,
request: storage.CreateReadSessionRequest = None,
request: Union[storage.CreateReadSessionRequest, dict] = None,
*,
parent: str = None,
read_session: stream.ReadSession = None,
@@ -423,7 +423,7 @@ def create_read_session(
caller.
Args:
request (google.cloud.bigquery_storage_v1.types.CreateReadSessionRequest):
request (Union[google.cloud.bigquery_storage_v1.types.CreateReadSessionRequest, dict]):
The request object. Request message for
`CreateReadSession`.
parent (str):
@@ -512,7 +512,7 @@ def create_read_session(

def read_rows(
self,
request: storage.ReadRowsRequest = None,
request: Union[storage.ReadRowsRequest, dict] = None,
*,
read_stream: str = None,
offset: int = None,
@@ -530,7 +530,7 @@ def read_rows(
reflecting the current state of the stream.
Args:
request (google.cloud.bigquery_storage_v1.types.ReadRowsRequest):
request (Union[google.cloud.bigquery_storage_v1.types.ReadRowsRequest, dict]):
The request object. Request message for `ReadRows`.
read_stream (str):
Required. Stream to read rows from.
@@ -602,7 +602,7 @@ def read_rows(

def split_read_stream(
self,
request: storage.SplitReadStreamRequest = None,
request: Union[storage.SplitReadStreamRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -623,7 +623,7 @@ def split_read_stream(
once the streams have been read to completion.
Args:
request (google.cloud.bigquery_storage_v1.types.SplitReadStreamRequest):
request (Union[google.cloud.bigquery_storage_v1.types.SplitReadStreamRequest, dict]):
The request object. Request message for
`SplitReadStream`.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -122,7 +122,7 @@ def __init__(
**scopes_kwargs, quota_project_id=quota_project_id
)

# If the credentials is service account credentials, then always try to use self signed JWT.
# If the credentials are service account credentials, then always try to use self signed JWT.
if (
always_use_jwt_access
and isinstance(credentials, service_account.Credentials)
@@ -82,16 +82,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
@@ -129,16 +129,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
@@ -17,17 +17,7 @@
from distutils import util
import os
import re
from typing import (
Callable,
Dict,
Optional,
Iterable,
Iterator,
Sequence,
Tuple,
Type,
Union,
)
from typing import Dict, Optional, Iterable, Iterator, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core import client_options as client_options_lib # type: ignore
@@ -383,7 +373,7 @@ def __init__(

def create_write_stream(
self,
request: storage.CreateWriteStreamRequest = None,
request: Union[storage.CreateWriteStreamRequest, dict] = None,
*,
parent: str = None,
write_stream: stream.WriteStream = None,
@@ -400,7 +390,7 @@ def create_write_stream(
received.
Args:
request (google.cloud.bigquery_storage_v1.types.CreateWriteStreamRequest):
request (Union[google.cloud.bigquery_storage_v1.types.CreateWriteStreamRequest, dict]):
The request object. Request message for
`CreateWriteStream`.
parent (str):
@@ -545,7 +535,7 @@ def append_rows(

def get_write_stream(
self,
request: storage.GetWriteStreamRequest = None,
request: Union[storage.GetWriteStreamRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -555,7 +545,7 @@ def get_write_stream(
r"""Gets information about a write stream.
Args:
request (google.cloud.bigquery_storage_v1.types.GetWriteStreamRequest):
request (Union[google.cloud.bigquery_storage_v1.types.GetWriteStreamRequest, dict]):
The request object. Request message for
`GetWriteStreamRequest`.
name (str):
@@ -617,7 +607,7 @@ def get_write_stream(

def finalize_write_stream(
self,
request: storage.FinalizeWriteStreamRequest = None,
request: Union[storage.FinalizeWriteStreamRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -628,7 +618,7 @@ def finalize_write_stream(
the stream. Finalize is not supported on the '_default' stream.
Args:
request (google.cloud.bigquery_storage_v1.types.FinalizeWriteStreamRequest):
request (Union[google.cloud.bigquery_storage_v1.types.FinalizeWriteStreamRequest, dict]):
The request object. Request message for invoking
`FinalizeWriteStream`.
name (str):
@@ -687,7 +677,7 @@ def finalize_write_stream(

def batch_commit_write_streams(
self,
request: storage.BatchCommitWriteStreamsRequest = None,
request: Union[storage.BatchCommitWriteStreamsRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -702,7 +692,7 @@ def batch_commit_write_streams(
becomes available for read operations.
Args:
request (google.cloud.bigquery_storage_v1.types.BatchCommitWriteStreamsRequest):
request (Union[google.cloud.bigquery_storage_v1.types.BatchCommitWriteStreamsRequest, dict]):
The request object. Request message for
`BatchCommitWriteStreams`.
parent (str):
@@ -764,7 +754,7 @@ def batch_commit_write_streams(

def flush_rows(
self,
request: storage.FlushRowsRequest = None,
request: Union[storage.FlushRowsRequest, dict] = None,
*,
write_stream: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -783,7 +773,7 @@ def flush_rows(
BUFFERED.
Args:
request (google.cloud.bigquery_storage_v1.types.FlushRowsRequest):
request (Union[google.cloud.bigquery_storage_v1.types.FlushRowsRequest, dict]):
The request object. Request message for `FlushRows`.
write_stream (str):
Required. The stream that is the
@@ -122,7 +122,7 @@ def __init__(
**scopes_kwargs, quota_project_id=quota_project_id
)

# If the credentials is service account credentials, then always try to use self signed JWT.
# If the credentials are service account credentials, then always try to use self signed JWT.
if (
always_use_jwt_access
and isinstance(credentials, service_account.Credentials)
@@ -84,16 +84,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
@@ -131,16 +131,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
@@ -17,7 +17,7 @@
from distutils import util
import os
import re
from typing import Callable, Dict, Optional, Iterable, Sequence, Tuple, Type, Union
from typing import Dict, Optional, Iterable, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core import client_options as client_options_lib # type: ignore
@@ -391,7 +391,7 @@ def __init__(

def create_read_session(
self,
request: storage.CreateReadSessionRequest = None,
request: Union[storage.CreateReadSessionRequest, dict] = None,
*,
parent: str = None,
read_session: stream.ReadSession = None,
@@ -425,7 +425,7 @@ def create_read_session(
caller.
Args:
request (google.cloud.bigquery_storage_v1beta2.types.CreateReadSessionRequest):
request (Union[google.cloud.bigquery_storage_v1beta2.types.CreateReadSessionRequest, dict]):
The request object. Request message for
`CreateReadSession`.
parent (str):
@@ -514,7 +514,7 @@ def create_read_session(

def read_rows(
self,
request: storage.ReadRowsRequest = None,
request: Union[storage.ReadRowsRequest, dict] = None,
*,
read_stream: str = None,
offset: int = None,
@@ -532,7 +532,7 @@ def read_rows(
reflecting the current state of the stream.
Args:
request (google.cloud.bigquery_storage_v1beta2.types.ReadRowsRequest):
request (Union[google.cloud.bigquery_storage_v1beta2.types.ReadRowsRequest, dict]):
The request object. Request message for `ReadRows`.
read_stream (str):
Required. Stream to read rows from.
@@ -604,7 +604,7 @@ def read_rows(

def split_read_stream(
self,
request: storage.SplitReadStreamRequest = None,
request: Union[storage.SplitReadStreamRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -625,7 +625,7 @@ def split_read_stream(
once the streams have been read to completion.
Args:
request (google.cloud.bigquery_storage_v1beta2.types.SplitReadStreamRequest):
request (Union[google.cloud.bigquery_storage_v1beta2.types.SplitReadStreamRequest, dict]):
The request object. Request message for
`SplitReadStream`.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -122,7 +122,7 @@ def __init__(
**scopes_kwargs, quota_project_id=quota_project_id
)

# If the credentials is service account credentials, then always try to use self signed JWT.
# If the credentials are service account credentials, then always try to use self signed JWT.
if (
always_use_jwt_access
and isinstance(credentials, service_account.Credentials)
@@ -84,16 +84,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.
@@ -131,16 +131,16 @@ def __init__(
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
If provided, it overrides the ``host`` argument and tries to create
a mutual TLS channel with client SSL credentials from
``client_cert_source`` or applicatin default SSL credentials.
``client_cert_source`` or application default SSL credentials.
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
Deprecated. A callback to provide client SSL certificate bytes and
private key bytes, both in PEM format. It is ignored if
``api_mtls_endpoint`` is None.
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
for grpc channel. It is ignored if ``channel`` is provided.
for the grpc channel. It is ignored if ``channel`` is provided.
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
A callback to provide client certificate bytes and private key bytes,
both in PEM format. It is used to configure mutual TLS channel. It is
both in PEM format. It is used to configure a mutual TLS channel. It is
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
quota_project_id (Optional[str]): An optional project to use for billing
and quota.

0 comments on commit a778080

Please sign in to comment.