Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

chore: use gapic-generator-python 0.65.1 #654

Merged
merged 3 commits into from
Apr 14, 2022
Merged

chore: use gapic-generator-python 0.65.1 #654

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
5e92691
chore: use gapic-generator-python 0.65.1
gcf-owl-bot[bot] Apr 13, 2022
359c1c8
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Apr 13, 2022
4652c3c
Merge branch 'main' into owl-bot-copy
parthea Apr 14, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 1 addition & 8 deletions google/pubsub_v1/services/publisher/async_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
from collections import OrderedDict
import functools
import re
from typing import Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core.client_options import ClientOptions
Expand Down Expand Up @@ -220,7 +220,6 @@ async def create_topic(
name rules]
(https://cloud.google.com/pubsub/docs/admin#resource_names).


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -329,7 +328,6 @@ async def update_topic(
r"""Updates an existing topic. Note that certain
properties of a topic are not modifiable.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -418,7 +416,6 @@ async def publish(
r"""Adds one or more messages to the topic. Returns ``NOT_FOUND`` if
the topic does not exist.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -758,7 +755,6 @@ async def list_topic_subscriptions(
r"""Lists the names of the attached subscriptions on this
topic.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -884,7 +880,6 @@ async def list_topic_snapshots(
bulk. That is, you can set the acknowledgment state of messages
in an existing subscription to the state captured by a snapshot.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1010,7 +1005,6 @@ async def delete_topic(
subscriptions to this topic are not deleted, but their ``topic``
field is set to ``_deleted-topic_``.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1107,7 +1101,6 @@ async def detach_subscription(
the subscription is a push subscription, pushes to the endpoint
will stop.


.. code-block:: python

from google import pubsub_v1
Expand Down
9 changes: 1 addition & 8 deletions google/pubsub_v1/services/publisher/client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
import functools
import os
import re
from typing import Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core import client_options as client_options_lib
Expand Down Expand Up @@ -503,7 +503,6 @@ def create_topic(
name rules]
(https://cloud.google.com/pubsub/docs/admin#resource_names).


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -604,7 +603,6 @@ def update_topic(
r"""Updates an existing topic. Note that certain
properties of a topic are not modifiable.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -686,7 +684,6 @@ def publish(
r"""Adds one or more messages to the topic. Returns ``NOT_FOUND`` if
the topic does not exist.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -992,7 +989,6 @@ def list_topic_subscriptions(
r"""Lists the names of the attached subscriptions on this
topic.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1108,7 +1104,6 @@ def list_topic_snapshots(
bulk. That is, you can set the acknowledgment state of messages
in an existing subscription to the state captured by a snapshot.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1224,7 +1219,6 @@ def delete_topic(
subscriptions to this topic are not deleted, but their ``topic``
field is set to ``_deleted-topic_``.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1313,7 +1307,6 @@ def detach_subscription(
the subscription is a push subscription, pushes to the endpoint
will stop.


.. code-block:: python

from google import pubsub_v1
Expand Down
5 changes: 5 additions & 0 deletions google/pubsub_v1/services/publisher/transports/base.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,7 @@ def __init__(
always_use_jwt_access (Optional[bool]): Whether self signed JWT should
be used for service account credentials.
"""

# Save the hostname. Default to port 443 (HTTPS) if none is specified.
if ":" not in host:
host += ":443"
Expand Down Expand Up @@ -391,5 +392,9 @@ def test_iam_permissions(
]:
raise NotImplementedError()

@property
def kind(self) -> str:
raise NotImplementedError()


__all__ = ("PublisherTransport",)
4 changes: 4 additions & 0 deletions google/pubsub_v1/services/publisher/transports/grpc.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -565,5 +565,9 @@ def test_iam_permissions(
def close(self):
self.grpc_channel.close()

@property
def kind(self) -> str:
return "grpc"


__all__ = ("PublisherGrpcTransport",)
2 changes: 1 addition & 1 deletion google/pubsub_v1/services/schema_service/async_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
from collections import OrderedDict
import functools
import re
from typing import Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core.client_options import ClientOptions
Expand Down
2 changes: 1 addition & 1 deletion google/pubsub_v1/services/schema_service/client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
from collections import OrderedDict
import os
import re
from typing import Dict, Optional, Sequence, Tuple, Type, Union
from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
import pkg_resources

from google.api_core import client_options as client_options_lib
Expand Down
5 changes: 5 additions & 0 deletions google/pubsub_v1/services/schema_service/transports/base.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,7 @@ def __init__(
always_use_jwt_access (Optional[bool]): Whether self signed JWT should
be used for service account credentials.
"""

# Save the hostname. Default to port 443 (HTTPS) if none is specified.
if ":" not in host:
host += ":443"
Expand Down Expand Up @@ -255,5 +256,9 @@ def test_iam_permissions(
]:
raise NotImplementedError()

@property
def kind(self) -> str:
raise NotImplementedError()


__all__ = ("SchemaServiceTransport",)
4 changes: 4 additions & 0 deletions google/pubsub_v1/services/schema_service/transports/grpc.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -468,5 +468,9 @@ def test_iam_permissions(
def close(self):
self.grpc_channel.close()

@property
def kind(self) -> str:
return "grpc"


__all__ = ("SchemaServiceGrpcTransport",)
15 changes: 1 addition & 14 deletions google/pubsub_v1/services/subscriber/async_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@
import re
from typing import (
Dict,
Mapping,
Optional,
AsyncIterable,
Awaitable,
Expand Down Expand Up @@ -245,7 +246,6 @@ async def create_subscription(
Note that for REST API requests, you must specify a name in the
request.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -518,7 +518,6 @@ async def update_subscription(
properties of a subscription, such as its topic, are not
modifiable.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -729,7 +728,6 @@ async def delete_subscription(
new one has no association with the old subscription or its
topic unless the same topic is specified.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -831,7 +829,6 @@ async def modify_ack_deadline(
does not modify the subscription-level ``ackDeadlineSeconds``
used for subsequent messages.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -961,7 +958,6 @@ async def acknowledge(
Acknowledging a message more than once will not result in an
error.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1071,7 +1067,6 @@ async def pull(
``UNAVAILABLE`` if there are too many concurrent pull requests
pending for the given subscription.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1219,7 +1214,6 @@ def streaming_pull(
re-establish the stream. Flow control can be achieved by
configuring the underlying RPC channel.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1321,7 +1315,6 @@ async def modify_push_config(
Messages will accumulate for delivery continuously through the
call regardless of changes to the ``PushConfig``.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1436,7 +1429,6 @@ async def get_snapshot(
acknowledgment state of messages in an existing
subscription to the state captured by a snapshot.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1550,7 +1542,6 @@ async def list_snapshots(
bulk. That is, you can set the acknowledgment state of messages
in an existing subscription to the state captured by a snapshot.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1688,7 +1679,6 @@ async def create_snapshot(
Note that for REST API requests, you must specify a name in the
request.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1826,7 +1816,6 @@ async def update_snapshot(
existing subscription to the state captured by a
snapshot.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -1924,7 +1913,6 @@ async def delete_snapshot(
no association with the old snapshot or its subscription, unless
the same subscription is specified.


.. code-block:: python

from google import pubsub_v1
Expand Down Expand Up @@ -2024,7 +2012,6 @@ async def seek(
Note that both the subscription and the snapshot must be on the
same topic.


.. code-block:: python

from google import pubsub_v1
Expand Down
Loading