Visitar URL original
chore: use gapic-generator-python 0.51.2 (#312) · googleapis/google-cloud-python@68fad4c · GitHub
Skip to content

Commit 68fad4c

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
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: googleapis/googleapis-gen@63a1db7 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjNhMWRiN2EzOGQ3NGI5NjM5NTkyZjUyMWVkMWRhYWY3Mjk5YWQ5YSJ9
1 parent f6c4c3b commit 68fad4c

17 files changed

Lines changed: 74 additions & 94 deletions

File tree

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_read/client.py‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
from distutils import util
1818
import os
1919
import re
20-
from typing import Callable, Dict, Optional, Iterable, Sequence, Tuple, Type, Union
20+
from typing import Dict, Optional, Iterable, Sequence, Tuple, Type, Union
2121
import pkg_resources
2222

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

390390
def create_read_session(
391391
self,
392-
request: storage.CreateReadSessionRequest = None,
392+
request: Union[storage.CreateReadSessionRequest, dict] = None,
393393
*,
394394
parent: str = None,
395395
read_session: stream.ReadSession = None,
@@ -423,7 +423,7 @@ def create_read_session(
423423
caller.
424424
425425
Args:
426-
request (google.cloud.bigquery_storage_v1.types.CreateReadSessionRequest):
426+
request (Union[google.cloud.bigquery_storage_v1.types.CreateReadSessionRequest, dict]):
427427
The request object. Request message for
428428
`CreateReadSession`.
429429
parent (str):
@@ -512,7 +512,7 @@ def create_read_session(
512512

513513
def read_rows(
514514
self,
515-
request: storage.ReadRowsRequest = None,
515+
request: Union[storage.ReadRowsRequest, dict] = None,
516516
*,
517517
read_stream: str = None,
518518
offset: int = None,
@@ -530,7 +530,7 @@ def read_rows(
530530
reflecting the current state of the stream.
531531
532532
Args:
533-
request (google.cloud.bigquery_storage_v1.types.ReadRowsRequest):
533+
request (Union[google.cloud.bigquery_storage_v1.types.ReadRowsRequest, dict]):
534534
The request object. Request message for `ReadRows`.
535535
read_stream (str):
536536
Required. Stream to read rows from.
@@ -602,7 +602,7 @@ def read_rows(
602602

603603
def split_read_stream(
604604
self,
605-
request: storage.SplitReadStreamRequest = None,
605+
request: Union[storage.SplitReadStreamRequest, dict] = None,
606606
*,
607607
retry: retries.Retry = gapic_v1.method.DEFAULT,
608608
timeout: float = None,
@@ -623,7 +623,7 @@ def split_read_stream(
623623
once the streams have been read to completion.
624624
625625
Args:
626-
request (google.cloud.bigquery_storage_v1.types.SplitReadStreamRequest):
626+
request (Union[google.cloud.bigquery_storage_v1.types.SplitReadStreamRequest, dict]):
627627
The request object. Request message for
628628
`SplitReadStream`.
629629
retry (google.api_core.retry.Retry): Designation of what errors, if any,

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_read/transports/base.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ def __init__(
122122
**scopes_kwargs, quota_project_id=quota_project_id
123123
)
124124

125-
# If the credentials is service account credentials, then always try to use self signed JWT.
125+
# If the credentials are service account credentials, then always try to use self signed JWT.
126126
if (
127127
always_use_jwt_access
128128
and isinstance(credentials, service_account.Credentials)

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc.py‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -82,16 +82,16 @@ def __init__(
8282
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
8383
If provided, it overrides the ``host`` argument and tries to create
8484
a mutual TLS channel with client SSL credentials from
85-
``client_cert_source`` or applicatin default SSL credentials.
85+
``client_cert_source`` or application default SSL credentials.
8686
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
8787
Deprecated. A callback to provide client SSL certificate bytes and
8888
private key bytes, both in PEM format. It is ignored if
8989
``api_mtls_endpoint`` is None.
9090
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
91-
for grpc channel. It is ignored if ``channel`` is provided.
91+
for the grpc channel. It is ignored if ``channel`` is provided.
9292
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
9393
A callback to provide client certificate bytes and private key bytes,
94-
both in PEM format. It is used to configure mutual TLS channel. It is
94+
both in PEM format. It is used to configure a mutual TLS channel. It is
9595
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
9696
quota_project_id (Optional[str]): An optional project to use for billing
9797
and quota.

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc_asyncio.py‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -129,16 +129,16 @@ def __init__(
129129
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
130130
If provided, it overrides the ``host`` argument and tries to create
131131
a mutual TLS channel with client SSL credentials from
132-
``client_cert_source`` or applicatin default SSL credentials.
132+
``client_cert_source`` or application default SSL credentials.
133133
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
134134
Deprecated. A callback to provide client SSL certificate bytes and
135135
private key bytes, both in PEM format. It is ignored if
136136
``api_mtls_endpoint`` is None.
137137
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
138-
for grpc channel. It is ignored if ``channel`` is provided.
138+
for the grpc channel. It is ignored if ``channel`` is provided.
139139
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
140140
A callback to provide client certificate bytes and private key bytes,
141-
both in PEM format. It is used to configure mutual TLS channel. It is
141+
both in PEM format. It is used to configure a mutual TLS channel. It is
142142
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
143143
quota_project_id (Optional[str]): An optional project to use for billing
144144
and quota.

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_write/client.py‎

Lines changed: 11 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -17,17 +17,7 @@
1717
from distutils import util
1818
import os
1919
import re
20-
from typing import (
21-
Callable,
22-
Dict,
23-
Optional,
24-
Iterable,
25-
Iterator,
26-
Sequence,
27-
Tuple,
28-
Type,
29-
Union,
30-
)
20+
from typing import Dict, Optional, Iterable, Iterator, Sequence, Tuple, Type, Union
3121
import pkg_resources
3222

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

384374
def create_write_stream(
385375
self,
386-
request: storage.CreateWriteStreamRequest = None,
376+
request: Union[storage.CreateWriteStreamRequest, dict] = None,
387377
*,
388378
parent: str = None,
389379
write_stream: stream.WriteStream = None,
@@ -400,7 +390,7 @@ def create_write_stream(
400390
received.
401391
402392
Args:
403-
request (google.cloud.bigquery_storage_v1.types.CreateWriteStreamRequest):
393+
request (Union[google.cloud.bigquery_storage_v1.types.CreateWriteStreamRequest, dict]):
404394
The request object. Request message for
405395
`CreateWriteStream`.
406396
parent (str):
@@ -545,7 +535,7 @@ def append_rows(
545535

546536
def get_write_stream(
547537
self,
548-
request: storage.GetWriteStreamRequest = None,
538+
request: Union[storage.GetWriteStreamRequest, dict] = None,
549539
*,
550540
name: str = None,
551541
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -555,7 +545,7 @@ def get_write_stream(
555545
r"""Gets information about a write stream.
556546
557547
Args:
558-
request (google.cloud.bigquery_storage_v1.types.GetWriteStreamRequest):
548+
request (Union[google.cloud.bigquery_storage_v1.types.GetWriteStreamRequest, dict]):
559549
The request object. Request message for
560550
`GetWriteStreamRequest`.
561551
name (str):
@@ -617,7 +607,7 @@ def get_write_stream(
617607

618608
def finalize_write_stream(
619609
self,
620-
request: storage.FinalizeWriteStreamRequest = None,
610+
request: Union[storage.FinalizeWriteStreamRequest, dict] = None,
621611
*,
622612
name: str = None,
623613
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -628,7 +618,7 @@ def finalize_write_stream(
628618
the stream. Finalize is not supported on the '_default' stream.
629619
630620
Args:
631-
request (google.cloud.bigquery_storage_v1.types.FinalizeWriteStreamRequest):
621+
request (Union[google.cloud.bigquery_storage_v1.types.FinalizeWriteStreamRequest, dict]):
632622
The request object. Request message for invoking
633623
`FinalizeWriteStream`.
634624
name (str):
@@ -687,7 +677,7 @@ def finalize_write_stream(
687677

688678
def batch_commit_write_streams(
689679
self,
690-
request: storage.BatchCommitWriteStreamsRequest = None,
680+
request: Union[storage.BatchCommitWriteStreamsRequest, dict] = None,
691681
*,
692682
parent: str = None,
693683
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -702,7 +692,7 @@ def batch_commit_write_streams(
702692
becomes available for read operations.
703693
704694
Args:
705-
request (google.cloud.bigquery_storage_v1.types.BatchCommitWriteStreamsRequest):
695+
request (Union[google.cloud.bigquery_storage_v1.types.BatchCommitWriteStreamsRequest, dict]):
706696
The request object. Request message for
707697
`BatchCommitWriteStreams`.
708698
parent (str):
@@ -764,7 +754,7 @@ def batch_commit_write_streams(
764754

765755
def flush_rows(
766756
self,
767-
request: storage.FlushRowsRequest = None,
757+
request: Union[storage.FlushRowsRequest, dict] = None,
768758
*,
769759
write_stream: str = None,
770760
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -783,7 +773,7 @@ def flush_rows(
783773
BUFFERED.
784774
785775
Args:
786-
request (google.cloud.bigquery_storage_v1.types.FlushRowsRequest):
776+
request (Union[google.cloud.bigquery_storage_v1.types.FlushRowsRequest, dict]):
787777
The request object. Request message for `FlushRows`.
788778
write_stream (str):
789779
Required. The stream that is the

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_write/transports/base.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ def __init__(
122122
**scopes_kwargs, quota_project_id=quota_project_id
123123
)
124124

125-
# If the credentials is service account credentials, then always try to use self signed JWT.
125+
# If the credentials are service account credentials, then always try to use self signed JWT.
126126
if (
127127
always_use_jwt_access
128128
and isinstance(credentials, service_account.Credentials)

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_write/transports/grpc.py‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -84,16 +84,16 @@ def __init__(
8484
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
8585
If provided, it overrides the ``host`` argument and tries to create
8686
a mutual TLS channel with client SSL credentials from
87-
``client_cert_source`` or applicatin default SSL credentials.
87+
``client_cert_source`` or application default SSL credentials.
8888
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
8989
Deprecated. A callback to provide client SSL certificate bytes and
9090
private key bytes, both in PEM format. It is ignored if
9191
``api_mtls_endpoint`` is None.
9292
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
93-
for grpc channel. It is ignored if ``channel`` is provided.
93+
for the grpc channel. It is ignored if ``channel`` is provided.
9494
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
9595
A callback to provide client certificate bytes and private key bytes,
96-
both in PEM format. It is used to configure mutual TLS channel. It is
96+
both in PEM format. It is used to configure a mutual TLS channel. It is
9797
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
9898
quota_project_id (Optional[str]): An optional project to use for billing
9999
and quota.

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_write/transports/grpc_asyncio.py‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -131,16 +131,16 @@ def __init__(
131131
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
132132
If provided, it overrides the ``host`` argument and tries to create
133133
a mutual TLS channel with client SSL credentials from
134-
``client_cert_source`` or applicatin default SSL credentials.
134+
``client_cert_source`` or application default SSL credentials.
135135
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
136136
Deprecated. A callback to provide client SSL certificate bytes and
137137
private key bytes, both in PEM format. It is ignored if
138138
``api_mtls_endpoint`` is None.
139139
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
140-
for grpc channel. It is ignored if ``channel`` is provided.
140+
for the grpc channel. It is ignored if ``channel`` is provided.
141141
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
142142
A callback to provide client certificate bytes and private key bytes,
143-
both in PEM format. It is used to configure mutual TLS channel. It is
143+
both in PEM format. It is used to configure a mutual TLS channel. It is
144144
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
145145
quota_project_id (Optional[str]): An optional project to use for billing
146146
and quota.

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1beta2/services/big_query_read/client.py‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
from distutils import util
1818
import os
1919
import re
20-
from typing import Callable, Dict, Optional, Iterable, Sequence, Tuple, Type, Union
20+
from typing import Dict, Optional, Iterable, Sequence, Tuple, Type, Union
2121
import pkg_resources
2222

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

392392
def create_read_session(
393393
self,
394-
request: storage.CreateReadSessionRequest = None,
394+
request: Union[storage.CreateReadSessionRequest, dict] = None,
395395
*,
396396
parent: str = None,
397397
read_session: stream.ReadSession = None,
@@ -425,7 +425,7 @@ def create_read_session(
425425
caller.
426426
427427
Args:
428-
request (google.cloud.bigquery_storage_v1beta2.types.CreateReadSessionRequest):
428+
request (Union[google.cloud.bigquery_storage_v1beta2.types.CreateReadSessionRequest, dict]):
429429
The request object. Request message for
430430
`CreateReadSession`.
431431
parent (str):
@@ -514,7 +514,7 @@ def create_read_session(
514514

515515
def read_rows(
516516
self,
517-
request: storage.ReadRowsRequest = None,
517+
request: Union[storage.ReadRowsRequest, dict] = None,
518518
*,
519519
read_stream: str = None,
520520
offset: int = None,
@@ -532,7 +532,7 @@ def read_rows(
532532
reflecting the current state of the stream.
533533
534534
Args:
535-
request (google.cloud.bigquery_storage_v1beta2.types.ReadRowsRequest):
535+
request (Union[google.cloud.bigquery_storage_v1beta2.types.ReadRowsRequest, dict]):
536536
The request object. Request message for `ReadRows`.
537537
read_stream (str):
538538
Required. Stream to read rows from.
@@ -604,7 +604,7 @@ def read_rows(
604604

605605
def split_read_stream(
606606
self,
607-
request: storage.SplitReadStreamRequest = None,
607+
request: Union[storage.SplitReadStreamRequest, dict] = None,
608608
*,
609609
retry: retries.Retry = gapic_v1.method.DEFAULT,
610610
timeout: float = None,
@@ -625,7 +625,7 @@ def split_read_stream(
625625
once the streams have been read to completion.
626626
627627
Args:
628-
request (google.cloud.bigquery_storage_v1beta2.types.SplitReadStreamRequest):
628+
request (Union[google.cloud.bigquery_storage_v1beta2.types.SplitReadStreamRequest, dict]):
629629
The request object. Request message for
630630
`SplitReadStream`.
631631
retry (google.api_core.retry.Retry): Designation of what errors, if any,

‎packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/base.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ def __init__(
122122
**scopes_kwargs, quota_project_id=quota_project_id
123123
)
124124

125-
# If the credentials is service account credentials, then always try to use self signed JWT.
125+
# If the credentials are service account credentials, then always try to use self signed JWT.
126126
if (
127127
always_use_jwt_access
128128
and isinstance(credentials, service_account.Credentials)

0 commit comments

Comments
 (0)