|
4 | 4 |
|
5 | 5 | [1]: https://pypi.org/project/google-cloud-pubsub/#history |
6 | 6 |
|
| 7 | +## 0.29.3 |
| 8 | + |
| 9 | +### Notable Implementation Changes |
| 10 | + |
| 11 | +- In subscription consumer thread: Making sure the request generator |
| 12 | + attached to an inactive bidirectional streaming pull is stopped before |
| 13 | + spawning a new request generator. This way we have a (fairly strong) |
| 14 | + guarantee that requests in the queue don't get sent into an inactive |
| 15 | + stream (#4503, #4554). |
| 16 | +- Adding `pause` / `resume` to subscription consumer thread and using these |
| 17 | + methods during flow control. The previous implementation tried to close the |
| 18 | + subscription (which involved 3 worker threads and 10 executors in a thread |
| 19 | + pool) and then re-open a new subscription. But, this was not entirely |
| 20 | + possible to shut down correctly from **within** one of the worker threads. |
| 21 | + Instead, we only pause the worker (of the 3) that is pulling new responses |
| 22 | + from the bidirectional streaming pull (#4558). |
| 23 | +- **Bug fix** (#4516): Using `max` where `min` was used by mistake to |
| 24 | + ensure the number of bytes tracked for subscription flow control |
| 25 | + remained non-negative (#4514). |
| 26 | +- Raising `TypeError` if `SubscriberClient.subscribe` receives a |
| 27 | + non-callable callback (#4497). |
| 28 | +- Shutting down thread pool executor when closing a subscriber |
| 29 | + policy (#4522). |
| 30 | +- Renaming `Policy.on_callback_request` to `Policy.dispatch_callback` |
| 31 | + and making the behavior much less dynamic (#4511). |
| 32 | +- Make sure subscription consumer thread doesn't try to join itself |
| 33 | + when exiting in error (#4540). |
| 34 | + |
| 35 | +### Dependencies |
| 36 | + |
| 37 | +- Upgrading `google-api-core` dependency to latest revision (`0.1.2`) |
| 38 | + since we rely on the latest version of the `concurrent.futures` backport |
| 39 | + to provide the `thread_name_prefix` argument for thread pool |
| 40 | + executor (#4521, #XYZ). |
| 41 | + |
| 42 | +PyPI: https://pypi.org/project/google-cloud-pubsub/0.29.3/ |
| 43 | + |
7 | 44 | ## 0.29.2 |
8 | 45 |
|
9 | 46 | ### Notable Implementation Changes |
|
0 commit comments