Skip to content

Commit

Permalink
Making new Pub / Sub and API core releases. (#4559)
Browse files Browse the repository at this point in the history
  • Loading branch information
dhermes authored Dec 8, 2017
1 parent ca10706 commit 1c70f25
Show file tree
Hide file tree
Showing 2 changed files with 39 additions and 2 deletions.
37 changes: 37 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,43 @@

[1]: https://pypi.org/project/google-cloud-pubsub/#history

## 0.29.3

### Notable Implementation Changes

- In subscription consumer thread: Making sure the request generator
attached to an inactive bidirectional streaming pull is stopped before
spawning a new request generator. This way we have a (fairly strong)
guarantee that requests in the queue don't get sent into an inactive
stream (#4503, #4554).
- Adding `pause` / `resume` to subscription consumer thread and using these
methods during flow control. The previous implementation tried to close the
subscription (which involved 3 worker threads and 10 executors in a thread
pool) and then re-open a new subscription. But, this was not entirely
possible to shut down correctly from **within** one of the worker threads.
Instead, we only pause the worker (of the 3) that is pulling new responses
from the bidirectional streaming pull (#4558).
- **Bug fix** (#4516): Using `max` where `min` was used by mistake to
ensure the number of bytes tracked for subscription flow control
remained non-negative (#4514).
- Raising `TypeError` if `SubscriberClient.subscribe` receives a
non-callable callback (#4497).
- Shutting down thread pool executor when closing a subscriber
policy (#4522).
- Renaming `Policy.on_callback_request` to `Policy.dispatch_callback`
and making the behavior much less dynamic (#4511).
- Make sure subscription consumer thread doesn't try to join itself
when exiting in error (#4540).

### Dependencies

- Upgrading `google-api-core` dependency to latest revision (`0.1.2`)
since we rely on the latest version of the `concurrent.futures` backport
to provide the `thread_name_prefix` argument for thread pool
executor (#4521, #XYZ).

PyPI: https://pypi.org/project/google-cloud-pubsub/0.29.3/

## 0.29.2

### Notable Implementation Changes
Expand Down
4 changes: 2 additions & 2 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -51,15 +51,15 @@


REQUIREMENTS = [
'google-api-core[grpc] >= 0.1.2.dev1, < 0.2.0dev',
'google-api-core[grpc] >= 0.1.2, < 0.2.0dev',
'google-auth >= 1.0.2, < 2.0dev',
'grpc-google-iam-v1 >= 0.11.1, < 0.12dev',
'psutil >= 5.2.2, < 6.0dev',
]

setup(
name='google-cloud-pubsub',
version='0.29.3.dev1',
version='0.29.3',
description='Python Client for Google Cloud Pub/Sub',
long_description=README,
namespace_packages=[
Expand Down

0 comments on commit 1c70f25

Please sign in to comment.