Updated google-cloud-pubsub to version 0.35 [(#1624)](GoogleCloudPlat…

…form/python-docs-samples#1624)

* Updated library version

* Rewrote test for publish with error handler

* Custom _publish function in test prints no 'Attributes'

samples/snippets/publisher_test.py

@@ -13,9 +13,11 @@
 # limitations under the License.
 
 import os
+import time
 
 from gcp_devrel.testing import eventually_consistent
 from google.cloud import pubsub_v1
+import mock
 import pytest
 
 import publisher
@@ -43,6 +45,19 @@ def topic(client):
     yield topic_path
 
 
+def _make_sleep_patch():
+    real_sleep = time.sleep
+
+    def new_sleep(period):
+        if period == 60:
+            real_sleep(5)
+            raise RuntimeError('sigil')
+        else:
+            real_sleep(period)
+
+    return mock.patch('time.sleep', new=new_sleep)
+
+
 def test_list(client, topic, capsys):
     @eventually_consistent.call
     def _():
@@ -96,7 +111,11 @@ def test_publish_with_batch_settings(topic, capsys):
 
 
 def test_publish_with_error_handler(topic, capsys):
-    publisher.publish_messages_with_error_handler(PROJECT, TOPIC)
+
+    with _make_sleep_patch():
+        with pytest.raises(RuntimeError, match='sigil'):
+            publisher.publish_messages_with_error_handler(
+                PROJECT, TOPIC)
 
     out, _ = capsys.readouterr()
     assert 'Published' in out

samples/snippets/requirements.txt

@@ -1 +1 @@
-google-cloud-pubsub==0.33.0
+google-cloud-pubsub==0.35.0

samples/snippets/subscriber.py

@@ -191,7 +191,7 @@ def receive_messages_with_flow_control(project, subscription_name):
         project, subscription_name)
 
     def callback(message):
-        print('Received message: {}'.format(message))
+        print('Received message: {}'.format(message.data))
         message.ack()
 
     # Limit the subscriber to only have ten outstanding messages at a time.

samples/snippets/subscriber_test.py

@@ -171,7 +171,6 @@ def test_receive_with_custom_attributes(
 
     out, _ = capsys.readouterr()
     assert 'Test message' in out
-    assert 'Attributes' in out
     assert 'origin' in out
     assert 'python-sample' in out