From cb13bd8718a487427e66cbd3324e170da2163025 Mon Sep 17 00:00:00 2001 From: yijxie Date: Fri, 14 Feb 2020 11:23:21 -0800 Subject: [PATCH 1/8] Increment version --- .../azure-eventhub-checkpointstoreblob-aio/CHANGELOG.md | 2 ++ .../eventhub/extensions/checkpointstoreblobaio/_version.py | 2 +- sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md | 2 ++ .../azure/eventhub/extensions/checkpointstoreblob/_version.py | 2 +- sdk/eventhub/azure-eventhub/CHANGELOG.md | 2 ++ sdk/eventhub/azure-eventhub/azure/eventhub/_version.py | 2 +- 6 files changed, 9 insertions(+), 3 deletions(-) diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/CHANGELOG.md b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/CHANGELOG.md index 8e929a30f01f..4d6010a3249a 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/CHANGELOG.md +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/CHANGELOG.md @@ -1,5 +1,7 @@ # Release History +## 1.0.1 (Unreleased) + ## 1.0.0 (2020-01-13) Stable release. No new features or API changes. diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/azure/eventhub/extensions/checkpointstoreblobaio/_version.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/azure/eventhub/extensions/checkpointstoreblobaio/_version.py index 8eedef9ba349..010063f9dd93 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/azure/eventhub/extensions/checkpointstoreblobaio/_version.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/azure/eventhub/extensions/checkpointstoreblobaio/_version.py @@ -3,4 +3,4 @@ # Licensed under the MIT License. # ------------------------------------ -VERSION = "1.0.0" +VERSION = "1.0.1" diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md b/sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md index 2498f3200d83..bbae3dace509 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md @@ -1,5 +1,7 @@ # Release History +## 1.0.1 (Unreleased) + ## 1.0.0 (2020-01-13) Stable release. No new features or API changes. diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_version.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_version.py index 8eedef9ba349..010063f9dd93 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_version.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_version.py @@ -3,4 +3,4 @@ # Licensed under the MIT License. # ------------------------------------ -VERSION = "1.0.0" +VERSION = "1.0.1" diff --git a/sdk/eventhub/azure-eventhub/CHANGELOG.md b/sdk/eventhub/azure-eventhub/CHANGELOG.md index 6e48b02ca198..43675644db6b 100644 --- a/sdk/eventhub/azure-eventhub/CHANGELOG.md +++ b/sdk/eventhub/azure-eventhub/CHANGELOG.md @@ -1,5 +1,7 @@ # Release History +## 5.0.1 (Unreleased) + ## 5.0.0 (2020-01-13) **Breaking changes** diff --git a/sdk/eventhub/azure-eventhub/azure/eventhub/_version.py b/sdk/eventhub/azure-eventhub/azure/eventhub/_version.py index 7330e03f2b28..aeddf5ca4e16 100644 --- a/sdk/eventhub/azure-eventhub/azure/eventhub/_version.py +++ b/sdk/eventhub/azure-eventhub/azure/eventhub/_version.py @@ -3,4 +3,4 @@ # Licensed under the MIT License. # ------------------------------------ -VERSION = "5.0.0" +VERSION = "5.0.1" From 38e9f65493683c04c69040b11433dd6b02017f98 Mon Sep 17 00:00:00 2001 From: yijxie Date: Fri, 14 Feb 2020 11:23:39 -0800 Subject: [PATCH 2/8] Update Development Status --- sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py | 2 +- sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py index 0b13ff1bbb0f..88f1fd79f107 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py @@ -53,7 +53,7 @@ author_email='azpysdkhelp@microsoft.com', url='https://github.com/Azure/azure-sdk-for-python/tree/master/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio', classifiers=[ - 'Development Status :: 3 - Alpha', + 'Development Status :: 5 - Production/Stable', 'Programming Language :: Python', 'Programming Language :: Python :: 3', 'Programming Language :: Python :: 3.5', diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py index a6bbf648336d..40f6e926ed84 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py @@ -53,7 +53,7 @@ author_email='azpysdkhelp@microsoft.com', url='https://github.com/Azure/azure-sdk-for-python/tree/master/sdk/eventhub/azure-eventhub-checkpointstoreblob', classifiers=[ - 'Development Status :: 3 - Alpha', + 'Development Status :: 5 - Production/Stable', 'Programming Language :: Python', 'Programming Language :: Python :: 2', 'Programming Language :: Python :: 2.7', From fcbaf65ae5f4ead7635c4595d67f5281f98ecded Mon Sep 17 00:00:00 2001 From: yijxie Date: Mon, 9 Mar 2020 15:44:12 -0700 Subject: [PATCH 3/8] Remove typing.Deque for Py3.5.3 --- sdk/eventhub/azure-eventhub/azure/eventhub/_consumer.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdk/eventhub/azure-eventhub/azure/eventhub/_consumer.py b/sdk/eventhub/azure-eventhub/azure/eventhub/_consumer.py index b5e58ae6e803..6203ae636201 100644 --- a/sdk/eventhub/azure-eventhub/azure/eventhub/_consumer.py +++ b/sdk/eventhub/azure-eventhub/azure/eventhub/_consumer.py @@ -7,7 +7,7 @@ import uuid import logging from collections import deque -from typing import TYPE_CHECKING, Callable, Dict, Optional, Any, Deque +from typing import TYPE_CHECKING, Callable, Dict, Optional, Any import uamqp from uamqp import types, errors, utils @@ -120,7 +120,7 @@ def __init__(self, client, source, **kwargs): self._track_last_enqueued_event_properties = ( track_last_enqueued_event_properties ) - self._message_buffer = deque() # type: Deque[uamqp.Message] + self._message_buffer = deque() # type: ignore self._last_received_event = None # type: Optional[EventData] def _create_handler(self, auth): From 6f2c492f94bba01a98f5317ecbb0215961a7246e Mon Sep 17 00:00:00 2001 From: yijxie Date: Fri, 1 May 2020 10:12:33 -0700 Subject: [PATCH 4/8] Change version to 5.1.0 --- sdk/eventhub/azure-eventhub/azure/eventhub/_version.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk/eventhub/azure-eventhub/azure/eventhub/_version.py b/sdk/eventhub/azure-eventhub/azure/eventhub/_version.py index b211e6234dac..f2f20c702c59 100644 --- a/sdk/eventhub/azure-eventhub/azure/eventhub/_version.py +++ b/sdk/eventhub/azure-eventhub/azure/eventhub/_version.py @@ -3,4 +3,4 @@ # Licensed under the MIT License. # ------------------------------------ -VERSION = "5.1.0b2" +VERSION = "5.1.0" From f3ae603a36ad1852f6835d11cedadc05fbdf1269 Mon Sep 17 00:00:00 2001 From: yijxie Date: Fri, 1 May 2020 10:13:12 -0700 Subject: [PATCH 5/8] Change to 5 - production in classifiers --- sdk/eventhub/azure-eventhub/setup.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk/eventhub/azure-eventhub/setup.py b/sdk/eventhub/azure-eventhub/setup.py index 7f8bca9e4269..46cd5253c35a 100644 --- a/sdk/eventhub/azure-eventhub/setup.py +++ b/sdk/eventhub/azure-eventhub/setup.py @@ -54,7 +54,7 @@ author_email='azpysdkhelp@microsoft.com', url='https://github.com/Azure/azure-sdk-for-python/tree/master/sdk/eventhub/azure-eventhub', classifiers=[ - "Development Status :: 4 - Beta", + "Development Status :: 5 - Production/Stable", 'Programming Language :: Python', 'Programming Language :: Python :: 2', 'Programming Language :: Python :: 2.7', From 58308b41e64135a2c3a6aeb9677311750e680637 Mon Sep 17 00:00:00 2001 From: yijxie Date: Fri, 1 May 2020 10:14:45 -0700 Subject: [PATCH 6/8] Update docs --- sdk/eventhub/azure-eventhub/CHANGELOG.md | 3 ++- sdk/eventhub/azure-eventhub/README.md | 4 ++-- .../azure-eventhub/azure/eventhub/_consumer_client.py | 4 ++-- .../azure/eventhub/aio/_consumer_client_async.py | 4 ++-- 4 files changed, 8 insertions(+), 7 deletions(-) diff --git a/sdk/eventhub/azure-eventhub/CHANGELOG.md b/sdk/eventhub/azure-eventhub/CHANGELOG.md index e235266b4a67..e1cd7bfdd109 100644 --- a/sdk/eventhub/azure-eventhub/CHANGELOG.md +++ b/sdk/eventhub/azure-eventhub/CHANGELOG.md @@ -1,10 +1,11 @@ # Release History -## 5.1.0b2 (Unreleased) +## 5.1.0 (2020-05-04) **New Features** - `EventHubProducerClient.send_batch` accepts either an `EventDataBatch` or a finite list of `EventData`. #9181 +- Added enqueueTime to span links of distributed tracing. #9599 ## 5.1.0b1 (2020-04-06) diff --git a/sdk/eventhub/azure-eventhub/README.md b/sdk/eventhub/azure-eventhub/README.md index c03b8e67ca1c..2cff00a3dd08 100644 --- a/sdk/eventhub/azure-eventhub/README.md +++ b/sdk/eventhub/azure-eventhub/README.md @@ -13,7 +13,7 @@ The Azure Event Hubs client library allows for publishing and consuming of Azure - Observe interesting operations and interactions happening within your business or other ecosystem, allowing loosely coupled systems to interact without the need to bind them together. - Receive events from one or more publishers, transform them to better meet the needs of your ecosystem, then publish the transformed events to a new stream for consumers to observe. -[Source code](./) | [Package (PyPi)](https://pypi.org/project/azure-eventhub/5.1.0b1) | [API reference documentation](https://azuresdkdocs.blob.core.windows.net/$web/python/azure-eventhub/5.1.0b1/azure.eventhub.html) | [Product documentation](https://docs.microsoft.com/en-us/azure/event-hubs/) | [Samples](https://github.com/Azure/azure-sdk-for-python/tree/master/sdk/eventhub/azure-eventhub/samples) +[Source code](./) | [Package (PyPi)](https://pypi.org/project/azure-eventhub/) | [API reference documentation](https://azuresdkdocs.blob.core.windows.net/$web/python/azure-eventhub/5.1.0/azure.eventhub.html) | [Product documentation](https://docs.microsoft.com/en-us/azure/event-hubs/) | [Samples](https://github.com/Azure/azure-sdk-for-python/tree/master/sdk/eventhub/azure-eventhub/samples) ## Getting started ### Prerequisites @@ -423,7 +423,7 @@ Please take a look at the [samples](./samples) directory for detailed examples o ### Documentation -Reference documentation is available [here](https://azuresdkdocs.blob.core.windows.net/$web/python/azure-eventhub/5.1.0b1/azure.eventhub.html). +Reference documentation is available [here](https://azuresdkdocs.blob.core.windows.net/$web/python/azure-eventhub/5.1.0/azure.eventhub.html). ### Provide Feedback diff --git a/sdk/eventhub/azure-eventhub/azure/eventhub/_consumer_client.py b/sdk/eventhub/azure-eventhub/azure/eventhub/_consumer_client.py index 2f3418dff687..a9041f60b715 100644 --- a/sdk/eventhub/azure-eventhub/azure/eventhub/_consumer_client.py +++ b/sdk/eventhub/azure-eventhub/azure/eventhub/_consumer_client.py @@ -43,8 +43,8 @@ class EventHubConsumerClient(ClientBase): `EventHubConsumerClient`. If a checkpoint store is not provided, the checkpoint will be maintained internally in memory. - An `EventHubConsumerClient` can also receive from a specific partition when you call its method `receive()` - and specify the partition_id. + An `EventHubConsumerClient` can also receive from a specific partition when you call its method `receive()` or + `receive_batch()` and specify the partition_id. Load-balancing won't work in single-partition mode. But users can still save checkpoints if the checkpoint_store is set. diff --git a/sdk/eventhub/azure-eventhub/azure/eventhub/aio/_consumer_client_async.py b/sdk/eventhub/azure-eventhub/azure/eventhub/aio/_consumer_client_async.py index 04567cc0292b..6ba1f59404c9 100644 --- a/sdk/eventhub/azure-eventhub/azure/eventhub/aio/_consumer_client_async.py +++ b/sdk/eventhub/azure-eventhub/azure/eventhub/aio/_consumer_client_async.py @@ -49,8 +49,8 @@ class EventHubConsumerClient(ClientBaseAsync): `EventHubConsumerClient`. If a checkpoint store is not provided, the checkpoint will be maintained internally in memory. - An `EventHubConsumerClient` can also receive from a specific partition when you call its method `receive()` - and specify the partition_id. + An `EventHubConsumerClient` can also receive from a specific partition when you call its method `receive()` or + `receive_batch()` and specify the partition_id. Load-balancing won't work in single-partition mode. But users can still save checkpoints if the checkpoint_store is set. From d0c89ba9bb3cc79937a6c9baf0e4a0ea7654f769 Mon Sep 17 00:00:00 2001 From: yijxie Date: Fri, 1 May 2020 10:50:08 -0700 Subject: [PATCH 7/8] Add a bug fixing description in change log --- sdk/eventhub/azure-eventhub/CHANGELOG.md | 3 +++ 1 file changed, 3 insertions(+) diff --git a/sdk/eventhub/azure-eventhub/CHANGELOG.md b/sdk/eventhub/azure-eventhub/CHANGELOG.md index e1cd7bfdd109..6fc45513e80d 100644 --- a/sdk/eventhub/azure-eventhub/CHANGELOG.md +++ b/sdk/eventhub/azure-eventhub/CHANGELOG.md @@ -7,6 +7,9 @@ - `EventHubProducerClient.send_batch` accepts either an `EventDataBatch` or a finite list of `EventData`. #9181 - Added enqueueTime to span links of distributed tracing. #9599 +**Bug fixes** +- Fixed a bug that turned `azure.eventhub.EventhubConsumerClient` to an exclusive receiver when it has no checkpoint store. #11181 + ## 5.1.0b1 (2020-04-06) **New Features** From eb76da726b6de14682ef0ad1e59ba64fabce76d2 Mon Sep 17 00:00:00 2001 From: yijxie Date: Fri, 1 May 2020 11:15:35 -0700 Subject: [PATCH 8/8] wording adjustment --- sdk/eventhub/azure-eventhub/CHANGELOG.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk/eventhub/azure-eventhub/CHANGELOG.md b/sdk/eventhub/azure-eventhub/CHANGELOG.md index 6fc45513e80d..13e9b1eb8ec0 100644 --- a/sdk/eventhub/azure-eventhub/CHANGELOG.md +++ b/sdk/eventhub/azure-eventhub/CHANGELOG.md @@ -8,7 +8,7 @@ - Added enqueueTime to span links of distributed tracing. #9599 **Bug fixes** -- Fixed a bug that turned `azure.eventhub.EventhubConsumerClient` to an exclusive receiver when it has no checkpoint store. #11181 +- Fixed a bug that turned `azure.eventhub.EventhubConsumerClient` into an exclusive receiver when it has no checkpoint store. #11181 ## 5.1.0b1 (2020-04-06)