Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
chore: use gapic-generator-python 0.51.2 (#505)
- [ ] 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
  • Loading branch information
gcf-owl-bot[bot] committed Sep 24, 2021
1 parent 7e623e5 commit b72522a
Show file tree
Hide file tree
Showing 13 changed files with 116 additions and 126 deletions.
38 changes: 19 additions & 19 deletions google/pubsub_v1/services/publisher/client.py
Expand Up @@ -18,7 +18,7 @@
import functools
import os
import re
from typing import Callable, Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Optional, Sequence, Tuple, Type, Union
import pkg_resources

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

def create_topic(
self,
request: pubsub.Topic = None,
request: Union[pubsub.Topic, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -420,7 +420,7 @@ def create_topic(
Args:
request (google.pubsub_v1.types.Topic):
request (Union[google.pubsub_v1.types.Topic, dict]):
The request object. A topic resource.
name (str):
Required. The name of the topic. It must have the format
Expand Down Expand Up @@ -485,7 +485,7 @@ def create_topic(

def update_topic(
self,
request: pubsub.UpdateTopicRequest = None,
request: Union[pubsub.UpdateTopicRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: TimeoutType = gapic_v1.method.DEFAULT,
Expand All @@ -496,7 +496,7 @@ def update_topic(
Args:
request (google.pubsub_v1.types.UpdateTopicRequest):
request (Union[google.pubsub_v1.types.UpdateTopicRequest, dict]):
The request object. Request for the UpdateTopic method.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
Expand Down Expand Up @@ -537,7 +537,7 @@ def update_topic(

def publish(
self,
request: pubsub.PublishRequest = None,
request: Union[pubsub.PublishRequest, dict] = None,
*,
topic: str = None,
messages: Sequence[pubsub.PubsubMessage] = None,
Expand All @@ -550,7 +550,7 @@ def publish(
Args:
request (google.pubsub_v1.types.PublishRequest):
request (Union[google.pubsub_v1.types.PublishRequest, dict]):
The request object. Request for the Publish method.
topic (str):
Required. The messages in the request will be published
Expand Down Expand Up @@ -617,7 +617,7 @@ def publish(

def get_topic(
self,
request: pubsub.GetTopicRequest = None,
request: Union[pubsub.GetTopicRequest, dict] = None,
*,
topic: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -628,7 +628,7 @@ def get_topic(
Args:
request (google.pubsub_v1.types.GetTopicRequest):
request (Union[google.pubsub_v1.types.GetTopicRequest, dict]):
The request object. Request for the GetTopic method.
topic (str):
Required. The name of the topic to get. Format is
Expand Down Expand Up @@ -687,7 +687,7 @@ def get_topic(

def list_topics(
self,
request: pubsub.ListTopicsRequest = None,
request: Union[pubsub.ListTopicsRequest, dict] = None,
*,
project: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -698,7 +698,7 @@ def list_topics(
Args:
request (google.pubsub_v1.types.ListTopicsRequest):
request (Union[google.pubsub_v1.types.ListTopicsRequest, dict]):
The request object. Request for the `ListTopics` method.
project (str):
Required. The name of the project in which to list
Expand Down Expand Up @@ -767,7 +767,7 @@ def list_topics(

def list_topic_subscriptions(
self,
request: pubsub.ListTopicSubscriptionsRequest = None,
request: Union[pubsub.ListTopicSubscriptionsRequest, dict] = None,
*,
topic: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -779,7 +779,7 @@ def list_topic_subscriptions(
Args:
request (google.pubsub_v1.types.ListTopicSubscriptionsRequest):
request (Union[google.pubsub_v1.types.ListTopicSubscriptionsRequest, dict]):
The request object. Request for the
`ListTopicSubscriptions` method.
topic (str):
Expand Down Expand Up @@ -850,7 +850,7 @@ def list_topic_subscriptions(

def list_topic_snapshots(
self,
request: pubsub.ListTopicSnapshotsRequest = None,
request: Union[pubsub.ListTopicSnapshotsRequest, dict] = None,
*,
topic: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -866,7 +866,7 @@ def list_topic_snapshots(
Args:
request (google.pubsub_v1.types.ListTopicSnapshotsRequest):
request (Union[google.pubsub_v1.types.ListTopicSnapshotsRequest, dict]):
The request object. Request for the `ListTopicSnapshots`
method.
topic (str):
Expand Down Expand Up @@ -937,7 +937,7 @@ def list_topic_snapshots(

def delete_topic(
self,
request: pubsub.DeleteTopicRequest = None,
request: Union[pubsub.DeleteTopicRequest, dict] = None,
*,
topic: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -953,7 +953,7 @@ def delete_topic(
Args:
request (google.pubsub_v1.types.DeleteTopicRequest):
request (Union[google.pubsub_v1.types.DeleteTopicRequest, dict]):
The request object. Request for the `DeleteTopic`
method.
topic (str):
Expand Down Expand Up @@ -1008,7 +1008,7 @@ def delete_topic(

def detach_subscription(
self,
request: pubsub.DetachSubscriptionRequest = None,
request: Union[pubsub.DetachSubscriptionRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: TimeoutType = gapic_v1.method.DEFAULT,
Expand All @@ -1022,7 +1022,7 @@ def detach_subscription(
Args:
request (google.pubsub_v1.types.DetachSubscriptionRequest):
request (Union[google.pubsub_v1.types.DetachSubscriptionRequest, dict]):
The request object. Request for the DetachSubscription
method.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
Expand Down
2 changes: 1 addition & 1 deletion google/pubsub_v1/services/publisher/transports/base.py
Expand Up @@ -123,7 +123,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)
Expand Down
6 changes: 3 additions & 3 deletions google/pubsub_v1/services/publisher/transports/grpc.py
Expand Up @@ -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.
Expand Down
Expand Up @@ -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.
Expand Down
26 changes: 13 additions & 13 deletions google/pubsub_v1/services/schema_service/client.py
Expand Up @@ -17,7 +17,7 @@
from distutils import util
import os
import re
from typing import Callable, Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Optional, Sequence, Tuple, Type, Union
import pkg_resources

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

def create_schema(
self,
request: gp_schema.CreateSchemaRequest = None,
request: Union[gp_schema.CreateSchemaRequest, dict] = None,
*,
parent: str = None,
schema: gp_schema.Schema = None,
Expand All @@ -362,7 +362,7 @@ def create_schema(
r"""Creates a schema.
Args:
request (google.pubsub_v1.types.CreateSchemaRequest):
request (Union[google.pubsub_v1.types.CreateSchemaRequest, dict]):
The request object. Request for the CreateSchema method.
parent (str):
Required. The name of the project in which to create the
Expand Down Expand Up @@ -445,7 +445,7 @@ def create_schema(

def get_schema(
self,
request: schema.GetSchemaRequest = None,
request: Union[schema.GetSchemaRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -455,7 +455,7 @@ def get_schema(
r"""Gets a schema.
Args:
request (google.pubsub_v1.types.GetSchemaRequest):
request (Union[google.pubsub_v1.types.GetSchemaRequest, dict]):
The request object. Request for the GetSchema method.
name (str):
Required. The name of the schema to get. Format is
Expand Down Expand Up @@ -513,7 +513,7 @@ def get_schema(

def list_schemas(
self,
request: schema.ListSchemasRequest = None,
request: Union[schema.ListSchemasRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -523,7 +523,7 @@ def list_schemas(
r"""Lists schemas in a project.
Args:
request (google.pubsub_v1.types.ListSchemasRequest):
request (Union[google.pubsub_v1.types.ListSchemasRequest, dict]):
The request object. Request for the `ListSchemas`
method.
parent (str):
Expand Down Expand Up @@ -592,7 +592,7 @@ def list_schemas(

def delete_schema(
self,
request: schema.DeleteSchemaRequest = None,
request: Union[schema.DeleteSchemaRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -602,7 +602,7 @@ def delete_schema(
r"""Deletes a schema.
Args:
request (google.pubsub_v1.types.DeleteSchemaRequest):
request (Union[google.pubsub_v1.types.DeleteSchemaRequest, dict]):
The request object. Request for the `DeleteSchema`
method.
name (str):
Expand Down Expand Up @@ -656,7 +656,7 @@ def delete_schema(

def validate_schema(
self,
request: gp_schema.ValidateSchemaRequest = None,
request: Union[gp_schema.ValidateSchemaRequest, dict] = None,
*,
parent: str = None,
schema: gp_schema.Schema = None,
Expand All @@ -667,7 +667,7 @@ def validate_schema(
r"""Validates a schema.
Args:
request (google.pubsub_v1.types.ValidateSchemaRequest):
request (Union[google.pubsub_v1.types.ValidateSchemaRequest, dict]):
The request object. Request for the `ValidateSchema`
method.
parent (str):
Expand Down Expand Up @@ -737,7 +737,7 @@ def validate_schema(

def validate_message(
self,
request: schema.ValidateMessageRequest = None,
request: Union[schema.ValidateMessageRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
Expand All @@ -746,7 +746,7 @@ def validate_message(
r"""Validates a message against a schema.
Args:
request (google.pubsub_v1.types.ValidateMessageRequest):
request (Union[google.pubsub_v1.types.ValidateMessageRequest, dict]):
The request object. Request for the `ValidateMessage`
method.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
Expand Down
Expand Up @@ -124,7 +124,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)
Expand Down
6 changes: 3 additions & 3 deletions google/pubsub_v1/services/schema_service/transports/grpc.py
Expand Up @@ -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.
Expand Down
Expand Up @@ -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.
Expand Down

0 comments on commit b72522a

Please sign in to comment.