From f85183bc4c75afcd7940c0a3fc84f19f72d9207b Mon Sep 17 00:00:00 2001 From: yoshi-automation Date: Tue, 18 Jun 2019 05:24:16 -0700 Subject: [PATCH] [CHANGE ME] Re-generated pubsub to pick up changes in the API or client library generator. --- pubsub/.coveragerc | 1 + pubsub/.flake8 | 1 + .../transports/publisher_grpc_transport.py | 8 +++-- .../transports/subscriber_grpc_transport.py | 8 +++-- .../cloud/pubsub_v1/proto/pubsub_pb2.py | 1 + pubsub/google/cloud/pubsub_v1/types.py | 33 +++++++++++++++++++ pubsub/noxfile.py | 2 ++ pubsub/setup.cfg | 1 + pubsub/synth.metadata | 10 +++--- 9 files changed, 56 insertions(+), 9 deletions(-) diff --git a/pubsub/.coveragerc b/pubsub/.coveragerc index 6b9ab9da4a1b..b178b094aa1d 100644 --- a/pubsub/.coveragerc +++ b/pubsub/.coveragerc @@ -1,3 +1,4 @@ +# Generated by synthtool. DO NOT EDIT! [run] branch = True diff --git a/pubsub/.flake8 b/pubsub/.flake8 index 61766fa84d02..0268ecc9c55c 100644 --- a/pubsub/.flake8 +++ b/pubsub/.flake8 @@ -1,3 +1,4 @@ +# Generated by synthtool. DO NOT EDIT! [flake8] ignore = E203, E266, E501, W503 exclude = diff --git a/pubsub/google/cloud/pubsub_v1/gapic/transports/publisher_grpc_transport.py b/pubsub/google/cloud/pubsub_v1/gapic/transports/publisher_grpc_transport.py index ff1878ea8d1d..38ecea168903 100644 --- a/pubsub/google/cloud/pubsub_v1/gapic/transports/publisher_grpc_transport.py +++ b/pubsub/google/cloud/pubsub_v1/gapic/transports/publisher_grpc_transport.py @@ -74,7 +74,9 @@ def __init__( } @classmethod - def create_channel(cls, address="pubsub.googleapis.com:443", credentials=None): + def create_channel( + cls, address="pubsub.googleapis.com:443", credentials=None, **kwargs + ): """Create and return a gRPC channel object. Args: @@ -84,12 +86,14 @@ def create_channel(cls, address="pubsub.googleapis.com:443", credentials=None): credentials identify this application to the service. If none are specified, the client will attempt to ascertain the credentials from the environment. + kwargs (dict): Keyword arguments, which are passed to the + channel creation. Returns: grpc.Channel: A gRPC channel object. """ return google.api_core.grpc_helpers.create_channel( - address, credentials=credentials, scopes=cls._OAUTH_SCOPES + address, credentials=credentials, scopes=cls._OAUTH_SCOPES, **kwargs ) @property diff --git a/pubsub/google/cloud/pubsub_v1/gapic/transports/subscriber_grpc_transport.py b/pubsub/google/cloud/pubsub_v1/gapic/transports/subscriber_grpc_transport.py index 1975250e96fb..794575b5551d 100644 --- a/pubsub/google/cloud/pubsub_v1/gapic/transports/subscriber_grpc_transport.py +++ b/pubsub/google/cloud/pubsub_v1/gapic/transports/subscriber_grpc_transport.py @@ -74,7 +74,9 @@ def __init__( } @classmethod - def create_channel(cls, address="pubsub.googleapis.com:443", credentials=None): + def create_channel( + cls, address="pubsub.googleapis.com:443", credentials=None, **kwargs + ): """Create and return a gRPC channel object. Args: @@ -84,12 +86,14 @@ def create_channel(cls, address="pubsub.googleapis.com:443", credentials=None): credentials identify this application to the service. If none are specified, the client will attempt to ascertain the credentials from the environment. + kwargs (dict): Keyword arguments, which are passed to the + channel creation. Returns: grpc.Channel: A gRPC channel object. """ return google.api_core.grpc_helpers.create_channel( - address, credentials=credentials, scopes=cls._OAUTH_SCOPES + address, credentials=credentials, scopes=cls._OAUTH_SCOPES, **kwargs ) @property diff --git a/pubsub/google/cloud/pubsub_v1/proto/pubsub_pb2.py b/pubsub/google/cloud/pubsub_v1/proto/pubsub_pb2.py index ace1751bbf46..62ea3b6d88ee 100644 --- a/pubsub/google/cloud/pubsub_v1/proto/pubsub_pb2.py +++ b/pubsub/google/cloud/pubsub_v1/proto/pubsub_pb2.py @@ -1,3 +1,4 @@ +# -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: google/cloud/pubsub_v1/proto/pubsub.proto diff --git a/pubsub/google/cloud/pubsub_v1/types.py b/pubsub/google/cloud/pubsub_v1/types.py index 0e73ce6b5588..f818d4aad80f 100644 --- a/pubsub/google/cloud/pubsub_v1/types.py +++ b/pubsub/google/cloud/pubsub_v1/types.py @@ -104,6 +104,39 @@ ) +if sys.version_info >= (3, 5): + FlowControl.__doc__ = ( + "The settings for controlling the rate at which messages are pulled " + "with an asynchronous subscription." + ) + FlowControl.max_bytes.__doc__ = ( + "The maximum total size of received - but not yet processed - messages " + "before pausing the message stream." + ) + FlowControl.max_messages.__doc__ = ( + "The maximum number of received - but not yet processed - messages before " + "pausing the message stream." + ) + FlowControl.resume_threshold.__doc__ = ( + "The relative threshold of the ``max_bytes`` and ``max_messages`` limits " + "below which to resume the message stream. Must be a positive number not " + "greater than ``1.0``." + ) + FlowControl.max_requests.__doc__ = "Currently not in use." + FlowControl.max_request_batch_size.__doc__ = ( + "The maximum number of requests scheduled by callbacks to process and " + "dispatch at a time." + ) + FlowControl.max_request_batch_latency.__doc__ = ( + "The maximum amount of time in seconds to wait for additional request " + "items before processing the next batch of requests." + ) + FlowControl.max_lease_duration.__doc__ = ( + "The maximum amount of time in seconds to hold a lease on a message " + "before dropping it from the lease management." + ) + + _shared_modules = [ http_pb2, iam_policy_pb2, diff --git a/pubsub/noxfile.py b/pubsub/noxfile.py index 968fb5a09bf1..f6257317fccd 100644 --- a/pubsub/noxfile.py +++ b/pubsub/noxfile.py @@ -14,6 +14,8 @@ # See the License for the specific language governing permissions and # limitations under the License. +# Generated by synthtool. DO NOT EDIT! + from __future__ import absolute_import import os import shutil diff --git a/pubsub/setup.cfg b/pubsub/setup.cfg index 2a9acf13daa9..3bd555500e37 100644 --- a/pubsub/setup.cfg +++ b/pubsub/setup.cfg @@ -1,2 +1,3 @@ +# Generated by synthtool. DO NOT EDIT! [bdist_wheel] universal = 1 diff --git a/pubsub/synth.metadata b/pubsub/synth.metadata index 0743cddffec8..09be1deb9f68 100644 --- a/pubsub/synth.metadata +++ b/pubsub/synth.metadata @@ -1,19 +1,19 @@ { - "updateTime": "2019-06-12T13:55:40.520528Z", + "updateTime": "2019-06-18T12:24:16.486264Z", "sources": [ { "generator": { "name": "artman", - "version": "0.24.1", - "dockerImage": "googleapis/artman@sha256:6018498e15310260dc9b03c9d576608908ed9fbabe42e1494ff3d827fea27b19" + "version": "0.27.0", + "dockerImage": "googleapis/artman@sha256:b036a7f4278d9deb5796f065e5c7f608d47d75369985ca7ab5039998120e972d" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "f117dac435e96ebe58d85280a3faf2350c4d4219", - "internalRef": "252714985" + "sha": "384aa843867c4d17756d14a01f047b6368494d32", + "internalRef": "253675319" } }, {