From a023aa144c1ca831a02266c862842eda9b1006d2 Mon Sep 17 00:00:00 2001 From: dpebot Date: Fri, 14 Sep 2018 05:15:38 -0700 Subject: [PATCH] Re-generate library using pubsub/synth.py --- .../cloud/pubsub_v1/gapic/publisher_client.py | 36 +++---- .../pubsub_v1/gapic/subscriber_client.py | 96 +++++++++---------- 2 files changed, 66 insertions(+), 66 deletions(-) diff --git a/pubsub/google/cloud/pubsub_v1/gapic/publisher_client.py b/pubsub/google/cloud/pubsub_v1/gapic/publisher_client.py index c3051a3ca31c..cb08721e1d05 100644 --- a/pubsub/google/cloud/pubsub_v1/gapic/publisher_client.py +++ b/pubsub/google/cloud/pubsub_v1/gapic/publisher_client.py @@ -248,8 +248,8 @@ def create_topic(self, 'create_topic'] = google.api_core.gapic_v1.method.wrap_method( self.transport.create_topic, default_retry=self._method_configs['CreateTopic'].retry, - default_timeout=self._method_configs['CreateTopic'] - .timeout, + default_timeout=self._method_configs['CreateTopic']. + timeout, client_info=self._client_info, ) @@ -320,8 +320,8 @@ def update_topic(self, 'update_topic'] = google.api_core.gapic_v1.method.wrap_method( self.transport.update_topic, default_retry=self._method_configs['UpdateTopic'].retry, - default_timeout=self._method_configs['UpdateTopic'] - .timeout, + default_timeout=self._method_configs['UpdateTopic']. + timeout, client_info=self._client_info, ) @@ -604,10 +604,10 @@ def list_topic_subscriptions( self._inner_api_calls[ 'list_topic_subscriptions'] = google.api_core.gapic_v1.method.wrap_method( self.transport.list_topic_subscriptions, - default_retry=self._method_configs[ - 'ListTopicSubscriptions'].retry, - default_timeout=self._method_configs[ - 'ListTopicSubscriptions'].timeout, + default_retry=self. + _method_configs['ListTopicSubscriptions'].retry, + default_timeout=self. + _method_configs['ListTopicSubscriptions'].timeout, client_info=self._client_info, ) @@ -675,8 +675,8 @@ def delete_topic(self, 'delete_topic'] = google.api_core.gapic_v1.method.wrap_method( self.transport.delete_topic, default_retry=self._method_configs['DeleteTopic'].retry, - default_timeout=self._method_configs['DeleteTopic'] - .timeout, + default_timeout=self._method_configs['DeleteTopic']. + timeout, client_info=self._client_info, ) @@ -741,8 +741,8 @@ def set_iam_policy(self, 'set_iam_policy'] = google.api_core.gapic_v1.method.wrap_method( self.transport.set_iam_policy, default_retry=self._method_configs['SetIamPolicy'].retry, - default_timeout=self._method_configs['SetIamPolicy'] - .timeout, + default_timeout=self._method_configs['SetIamPolicy']. + timeout, client_info=self._client_info, ) @@ -801,8 +801,8 @@ def get_iam_policy(self, 'get_iam_policy'] = google.api_core.gapic_v1.method.wrap_method( self.transport.get_iam_policy, default_retry=self._method_configs['GetIamPolicy'].retry, - default_timeout=self._method_configs['GetIamPolicy'] - .timeout, + default_timeout=self._method_configs['GetIamPolicy']. + timeout, client_info=self._client_info, ) @@ -865,10 +865,10 @@ def test_iam_permissions(self, self._inner_api_calls[ 'test_iam_permissions'] = google.api_core.gapic_v1.method.wrap_method( self.transport.test_iam_permissions, - default_retry=self._method_configs[ - 'TestIamPermissions'].retry, - default_timeout=self._method_configs['TestIamPermissions'] - .timeout, + default_retry=self._method_configs['TestIamPermissions']. + retry, + default_timeout=self._method_configs['TestIamPermissions']. + timeout, client_info=self._client_info, ) diff --git a/pubsub/google/cloud/pubsub_v1/gapic/subscriber_client.py b/pubsub/google/cloud/pubsub_v1/gapic/subscriber_client.py index a0d3750822ce..48ce0f8e7540 100644 --- a/pubsub/google/cloud/pubsub_v1/gapic/subscriber_client.py +++ b/pubsub/google/cloud/pubsub_v1/gapic/subscriber_client.py @@ -321,10 +321,10 @@ def create_subscription(self, self._inner_api_calls[ 'create_subscription'] = google.api_core.gapic_v1.method.wrap_method( self.transport.create_subscription, - default_retry=self._method_configs[ - 'CreateSubscription'].retry, - default_timeout=self._method_configs['CreateSubscription'] - .timeout, + default_retry=self._method_configs['CreateSubscription']. + retry, + default_timeout=self._method_configs['CreateSubscription']. + timeout, client_info=self._client_info, ) @@ -384,10 +384,10 @@ def get_subscription(self, self._inner_api_calls[ 'get_subscription'] = google.api_core.gapic_v1.method.wrap_method( self.transport.get_subscription, - default_retry=self._method_configs[ - 'GetSubscription'].retry, - default_timeout=self._method_configs['GetSubscription'] - .timeout, + default_retry=self._method_configs['GetSubscription']. + retry, + default_timeout=self._method_configs['GetSubscription']. + timeout, client_info=self._client_info, ) @@ -451,10 +451,10 @@ def update_subscription(self, self._inner_api_calls[ 'update_subscription'] = google.api_core.gapic_v1.method.wrap_method( self.transport.update_subscription, - default_retry=self._method_configs[ - 'UpdateSubscription'].retry, - default_timeout=self._method_configs['UpdateSubscription'] - .timeout, + default_retry=self._method_configs['UpdateSubscription']. + retry, + default_timeout=self._method_configs['UpdateSubscription']. + timeout, client_info=self._client_info, ) @@ -530,10 +530,10 @@ def list_subscriptions(self, self._inner_api_calls[ 'list_subscriptions'] = google.api_core.gapic_v1.method.wrap_method( self.transport.list_subscriptions, - default_retry=self._method_configs[ - 'ListSubscriptions'].retry, - default_timeout=self._method_configs['ListSubscriptions'] - .timeout, + default_retry=self._method_configs['ListSubscriptions']. + retry, + default_timeout=self._method_configs['ListSubscriptions']. + timeout, client_info=self._client_info, ) @@ -600,10 +600,10 @@ def delete_subscription(self, self._inner_api_calls[ 'delete_subscription'] = google.api_core.gapic_v1.method.wrap_method( self.transport.delete_subscription, - default_retry=self._method_configs[ - 'DeleteSubscription'].retry, - default_timeout=self._method_configs['DeleteSubscription'] - .timeout, + default_retry=self._method_configs['DeleteSubscription']. + retry, + default_timeout=self._method_configs['DeleteSubscription']. + timeout, client_info=self._client_info, ) @@ -673,10 +673,10 @@ def modify_ack_deadline(self, self._inner_api_calls[ 'modify_ack_deadline'] = google.api_core.gapic_v1.method.wrap_method( self.transport.modify_ack_deadline, - default_retry=self._method_configs[ - 'ModifyAckDeadline'].retry, - default_timeout=self._method_configs['ModifyAckDeadline'] - .timeout, + default_retry=self._method_configs['ModifyAckDeadline']. + retry, + default_timeout=self._method_configs['ModifyAckDeadline']. + timeout, client_info=self._client_info, ) @@ -742,8 +742,8 @@ def acknowledge(self, 'acknowledge'] = google.api_core.gapic_v1.method.wrap_method( self.transport.acknowledge, default_retry=self._method_configs['Acknowledge'].retry, - default_timeout=self._method_configs['Acknowledge'] - .timeout, + default_timeout=self._method_configs['Acknowledge']. + timeout, client_info=self._client_info, ) @@ -887,8 +887,8 @@ def streaming_pull(self, 'streaming_pull'] = google.api_core.gapic_v1.method.wrap_method( self.transport.streaming_pull, default_retry=self._method_configs['StreamingPull'].retry, - default_timeout=self._method_configs['StreamingPull'] - .timeout, + default_timeout=self._method_configs['StreamingPull']. + timeout, client_info=self._client_info, ) @@ -953,10 +953,10 @@ def modify_push_config(self, self._inner_api_calls[ 'modify_push_config'] = google.api_core.gapic_v1.method.wrap_method( self.transport.modify_push_config, - default_retry=self._method_configs[ - 'ModifyPushConfig'].retry, - default_timeout=self._method_configs['ModifyPushConfig'] - .timeout, + default_retry=self._method_configs['ModifyPushConfig']. + retry, + default_timeout=self._method_configs['ModifyPushConfig']. + timeout, client_info=self._client_info, ) @@ -1036,8 +1036,8 @@ def list_snapshots(self, 'list_snapshots'] = google.api_core.gapic_v1.method.wrap_method( self.transport.list_snapshots, default_retry=self._method_configs['ListSnapshots'].retry, - default_timeout=self._method_configs['ListSnapshots'] - .timeout, + default_timeout=self._method_configs['ListSnapshots']. + timeout, client_info=self._client_info, ) @@ -1135,8 +1135,8 @@ def create_snapshot(self, 'create_snapshot'] = google.api_core.gapic_v1.method.wrap_method( self.transport.create_snapshot, default_retry=self._method_configs['CreateSnapshot'].retry, - default_timeout=self._method_configs['CreateSnapshot'] - .timeout, + default_timeout=self._method_configs['CreateSnapshot']. + timeout, client_info=self._client_info, ) @@ -1208,8 +1208,8 @@ def update_snapshot(self, 'update_snapshot'] = google.api_core.gapic_v1.method.wrap_method( self.transport.update_snapshot, default_retry=self._method_configs['UpdateSnapshot'].retry, - default_timeout=self._method_configs['UpdateSnapshot'] - .timeout, + default_timeout=self._method_configs['UpdateSnapshot']. + timeout, client_info=self._client_info, ) @@ -1269,8 +1269,8 @@ def delete_snapshot(self, 'delete_snapshot'] = google.api_core.gapic_v1.method.wrap_method( self.transport.delete_snapshot, default_retry=self._method_configs['DeleteSnapshot'].retry, - default_timeout=self._method_configs['DeleteSnapshot'] - .timeout, + default_timeout=self._method_configs['DeleteSnapshot']. + timeout, client_info=self._client_info, ) @@ -1420,8 +1420,8 @@ def set_iam_policy(self, 'set_iam_policy'] = google.api_core.gapic_v1.method.wrap_method( self.transport.set_iam_policy, default_retry=self._method_configs['SetIamPolicy'].retry, - default_timeout=self._method_configs['SetIamPolicy'] - .timeout, + default_timeout=self._method_configs['SetIamPolicy']. + timeout, client_info=self._client_info, ) @@ -1480,8 +1480,8 @@ def get_iam_policy(self, 'get_iam_policy'] = google.api_core.gapic_v1.method.wrap_method( self.transport.get_iam_policy, default_retry=self._method_configs['GetIamPolicy'].retry, - default_timeout=self._method_configs['GetIamPolicy'] - .timeout, + default_timeout=self._method_configs['GetIamPolicy']. + timeout, client_info=self._client_info, ) @@ -1544,10 +1544,10 @@ def test_iam_permissions(self, self._inner_api_calls[ 'test_iam_permissions'] = google.api_core.gapic_v1.method.wrap_method( self.transport.test_iam_permissions, - default_retry=self._method_configs[ - 'TestIamPermissions'].retry, - default_timeout=self._method_configs['TestIamPermissions'] - .timeout, + default_retry=self._method_configs['TestIamPermissions']. + retry, + default_timeout=self._method_configs['TestIamPermissions']. + timeout, client_info=self._client_info, )