Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Event Hubs] Fix a bug that sets owner level 0 #11172

Merged
merged 32 commits into from
May 1, 2020
Merged
Changes from 31 commits
Commits
Show all changes
32 commits
Select commit Hold shift + click to select a range
cb13bd8
Increment version
Feb 14, 2020
38e9f65
Update Development Status
Feb 14, 2020
aa30bc0
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Feb 15, 2020
c4710ea
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Feb 20, 2020
053f073
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Feb 24, 2020
f0697f7
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 6, 2020
c83241a
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 6, 2020
18c6fba
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 6, 2020
607f134
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 9, 2020
88fd7d1
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 9, 2020
fcbaf65
Remove typing.Deque for Py3.5.3
Mar 9, 2020
f52e2d9
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 10, 2020
8aaaf1e
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 11, 2020
a12351c
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 25, 2020
cc9dbb9
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 27, 2020
932336a
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 30, 2020
2742ca0
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Mar 31, 2020
72ab463
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 2, 2020
213bb9d
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 3, 2020
b312d19
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 6, 2020
0638b9a
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 6, 2020
c7bd430
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 7, 2020
de47f42
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 7, 2020
2fcc005
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 15, 2020
cfa9d81
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 20, 2020
ac224c1
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 23, 2020
1305495
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 27, 2020
2183d32
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 29, 2020
e233d8c
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 29, 2020
fa41059
Merge branch 'master' of github.com:Azure/azure-sdk-for-python
Apr 30, 2020
9f69130
Fix a bug of sync owner_level
May 1, 2020
3a171c5
Allow live test to proceed if fail to import azure identity
May 1, 2020
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -74,9 +74,8 @@ def __init__(
self._partition_close_handler = kwargs.get(
"on_partition_close", None
) # type: Optional[Callable[[PartitionContext, CloseReason], None]]
self._checkpoint_store = kwargs.get(
"checkpoint_store"
) or InMemoryCheckpointStore() # type: Optional[CheckpointStore]
checkpoint_store = kwargs.get("checkpoint_store") # type: Optional[CheckpointStore]
self._checkpoint_store = checkpoint_store or InMemoryCheckpointStore()
self._initial_event_position = kwargs.get(
"initial_event_position", "@latest"
) # type: Union[str, int, datetime, Dict[str, Any]]
Expand All @@ -93,7 +92,7 @@ def __init__(

# Receive parameters
self._owner_level = kwargs.get("owner_level", None) # type: Optional[int]
if "checkpoint_store" in kwargs and self._owner_level is None:
if checkpoint_store and self._owner_level is None:
self._owner_level = 0
self._prefetch = kwargs.get("prefetch", None) # type: Optional[int]
self._track_last_enqueued_event_properties = kwargs.get(
Expand Down