in optional-kubernetes-engine/bookshelf/tasks.py [0:0]
def get_books_queue():
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(
publisher_client, subscriber_client, project,
'books', extra_context=current_app.app_context)