-
Notifications
You must be signed in to change notification settings - Fork 1.6k
Closed
Labels
api: pubsubIssues related to the Pub/Sub API.Issues related to the Pub/Sub API.
Description
Calling sub.pull() sometimes results in deadline exceeded exceptions from lower layer, I believe when the topic is empty.
Traceback (most recent call last):
File "/usr/lib/python2.7/runpy.py", line 162, in _run_module_as_main
"__main__", fname, loader, pkg_name)
File "/usr/lib/python2.7/runpy.py", line 72, in _run_code
exec code in run_globals
File "/tlaloc/python/tlaloc/data/bq_loader.py", line 145, in <module>
pulled = sub.pull()
File "/usr/local/lib/python2.7/dist-packages/google/cloud/pubsub/subscription.py", line 325, in pull
self.full_name, return_immediately, max_messages)
File "/usr/local/lib/python2.7/dist-packages/google/cloud/pubsub/_gax.py", line 396, in subscription_pull
return_immediately=return_immediately)
File "/usr/local/lib/python2.7/dist-packages/google/cloud/gapic/pubsub/v1/subscriber_api.py", line 545, in pull
return self._pull(request, options)
File "/usr/local/lib/python2.7/dist-packages/google/gax/api_callable.py", line 481, in inner
return api_caller(api_call, this_settings, request)
File "/usr/local/lib/python2.7/dist-packages/google/gax/api_callable.py", line 469, in base_caller
return api_call(*args)
File "/usr/local/lib/python2.7/dist-packages/google/gax/api_callable.py", line 434, in inner
errors.create_error('RPC failed', cause=exception))
File "/usr/local/lib/python2.7/dist-packages/google/gax/api_callable.py", line 430, in inner
return a_func(*args, **kwargs)
File "/usr/local/lib/python2.7/dist-packages/google/gax/api_callable.py", line 64, in inner
return a_func(*updated_args, **kwargs)
File "/usr/local/lib/python2.7/dist-packages/grpc/_channel.py", line 481, in __call__
return _end_unary_response_blocking(state, False, deadline)
File "/usr/local/lib/python2.7/dist-packages/grpc/_channel.py", line 432, in _end_unary_response_blocking
raise _Rendezvous(state, None, None, deadline)
google.gax.errors.GaxError: GaxError(RPC failed, caused by <_Rendezvous of RPC that terminated with (StatusCode.DEADLINE_EXCEEDED, Deadline Exceeded)>)(tlaloc-dev)Matts-MacBook-Air-2:notebooks mwytock$ pip show google-cloud
---
Metadata-Version: 2.0
Name: google-cloud
Version: 0.20.0
Summary: API Client library for Google Cloud
Home-page: https://github.com/GoogleCloudPlatform/google-cloud-python
Author: Google Cloud Platform
Author-email: [email protected]
Installer: pip
License: Apache 2.0
Location: /Users/mwytock/tlaloc-dev/lib/python2.7/site-packages
Requires: google-cloud-vision, google-cloud-monitoring, google-cloud-core, google-cloud-error-reporting, google-cloud-pubsub, google-cloud-storage, google-cloud-logging, google-cloud-datastore, google-cloud-bigtable, google-cloud-resource-manager, google-cloud-bigquery, google-cloud-dns, google-cloud-translate, google-cloud-language
Classifiers:
Development Status :: 4 - Beta
Intended Audience :: Developers
License :: OSI Approved :: Apache Software License
Operating System :: OS Independent
Programming Language :: Python :: 2
Programming Language :: Python :: 2.7
Programming Language :: Python :: 3
Programming Language :: Python :: 3.4
Programming Language :: Python :: 3.5
Topic :: Internet
Metadata
Metadata
Assignees
Labels
api: pubsubIssues related to the Pub/Sub API.Issues related to the Pub/Sub API.