Update optional-kubernetes-engine to use new psq

Jon Wayne Parrott · Jon Wayne Parrott · commit 07d2f10cfe78 · 2017-12-07T13:28:35.000-08:00
diff --git a/optional-kubernetes-engine/bookshelf/tasks.py b/optional-kubernetes-engine/bookshelf/tasks.py
@@ -21,16 +21,20 @@
 import requests
 
 
+publisher_client = pubsub.PublisherClient()
+subscriber_client = pubsub.SubscriberClient()
+
+
 def get_books_queue():
-    client = pubsub.Client(
-        project=current_app.config['PROJECT_ID'])
+    project = current_app.config['PROJECT_ID']
 
     # Create a queue specifically for processing books and pass in the
     # Flask application context. This ensures that tasks will have access
     # to any extensions / configuration specified to the app, such as
     # models.
     return psq.Queue(
-        client, 'books', extra_context=current_app.app_context)
+        publisher_client, subscriber_client, project,
+        'books', extra_context=current_app.app_context)
 
 
 def process_book(book_id):
diff --git a/optional-kubernetes-engine/requirements.txt b/optional-kubernetes-engine/requirements.txt
@@ -1,6 +1,8 @@
 Flask==0.12.2
 google-cloud-datastore==1.4.0
 google-cloud-storage==1.6.0
+google-cloud-logging==1.4.0
+google-cloud-error_reporting==0.28.0
 gunicorn==19.7.1
 oauth2client==4.1.2
 mock==2.0.0
