Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
44 commits
Select commit Hold shift + click to select a range
64da8ed
Small changes from code review
Aug 23, 2019
d951dcf
change EventData.msg_properties to private attribute
Aug 26, 2019
8bbac25
remove abstract method
Aug 27, 2019
70a33d0
code clean 1
Aug 28, 2019
abbdd25
code clean 2
Aug 28, 2019
b45d6b3
Fix pylint
Aug 29, 2019
247004a
Fix pylint
Aug 29, 2019
6ace6ce
Use properties EventData.partition_key
Aug 29, 2019
008421d
Small changes from code review
Aug 23, 2019
b8c027d
change EventData.msg_properties to private attribute
Aug 26, 2019
2489dd3
remove abstract method
Aug 27, 2019
3a2d72f
code clean 1
Aug 28, 2019
9735756
code clean 2
Aug 28, 2019
288617e
Fix pylint
Aug 29, 2019
2bdbffe
Fix pylint
Aug 29, 2019
e8ea699
Use properties EventData.partition_key
Aug 29, 2019
889597c
Merge branch 'eventhubs_preview3' of github.com:Azure/azure-sdk-for-p…
Aug 29, 2019
cb08478
Use properties EventData.partition_key
Aug 29, 2019
b3dcd07
Temporarily disable pylint errors that need refactoring
Aug 29, 2019
b85e6cc
fix pylint errors
Aug 29, 2019
92feb09
Merge branch 'master' into eventhubs_preview3
Aug 29, 2019
5e51ce2
fix pylint errors
Aug 30, 2019
726bf6f
ignore eventprocessor pylint temporarily
Aug 30, 2019
ffd8cb0
small pylint adjustment
Aug 30, 2019
2f69d65
Merge branch 'master' into eventhubs_preview3
Aug 30, 2019
e5c8d1c
Add typing for Python2.7
Aug 30, 2019
e85ac17
[EventHub] IoTHub management operations improvement and bug fixing (#…
yunhaoling Sep 2, 2019
1fb341b
[EventHub] Retry refactor (#7026)
yunhaoling Sep 3, 2019
7762130
add system_properties to EventData
Sep 3, 2019
1b10d00
Fix a small bug
Sep 4, 2019
13237b5
Refine example code
Sep 4, 2019
998eeed
Update receive method (#7064)
yunhaoling Sep 4, 2019
e13ddee
Update accessibility of class (#7091)
yunhaoling Sep 6, 2019
f616f37
Update samples and codes according to the review (#7098)
yunhaoling Sep 6, 2019
dad5baa
Python EventHubs load balancing (#6901)
YijunXieMS Sep 7, 2019
8e7e1c1
Fix a pylint error
Sep 7, 2019
13a8fe7
Eventhubs blobstorage checkpointstore merge to preview3 (#7109)
YijunXieMS Sep 7, 2019
b5c933f
exclude eventprocessor test for python27
Sep 7, 2019
7b0f5fe
exclude eventprocessor test
Sep 7, 2019
167361e
Revert "Eventhubs blobstorage checkpointstore merge to preview3 (#7109)"
Sep 7, 2019
1253983
Fix small problem in consumer iterator (#7110)
yunhaoling Sep 7, 2019
548a989
Fixed an issue that initializes partition processor multiple times
Sep 8, 2019
725b333
Update release history for 5.0.0b3
Sep 9, 2019
c359042
Update README for 5.0.0b3
Sep 9, 2019
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
Prev Previous commit
Next Next commit
code clean 2
  • Loading branch information
yijxie committed Aug 29, 2019
commit 97357562aa84c383bd9db700724f657ba4c94e04
2 changes: 1 addition & 1 deletion sdk/eventhub/azure-eventhubs/azure/eventhub/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
from azure.eventhub.client import EventHubClient
from azure.eventhub.producer import EventHubProducer
from azure.eventhub.consumer import EventHubConsumer
from uamqp import constants
from uamqp import constants # type: ignore
from .common import EventHubSharedKeyCredential, EventHubSASTokenCredential

TransportType = constants.TransportType
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
import logging
import time

from uamqp import errors, constants, compat
from uamqp import errors, constants, compat # type: ignore
from azure.eventhub.error import EventHubError, _handle_exception

log = logging.getLogger(__name__)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
import logging
import time

from uamqp import errors, constants, compat
from uamqp import errors, constants, compat # type: ignore
from azure.eventhub.error import EventHubError, ConnectError
from ..aio.error_async import _handle_exception

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,11 @@
import asyncio
from typing import Any, List, Dict

from uamqp import authentication, constants
from uamqp import authentication, constants # type: ignore
from uamqp import (
Message,
AMQPClientAsync,
)
) # type: ignore

from azure.eventhub.common import parse_sas_token, EventPosition, EventHubSharedKeyCredential, EventHubSASTokenCredential
from ..client_abstract import EventHubClientAbstract
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,8 @@
from typing import List
import time

from uamqp import errors, types
from uamqp import ReceiveClientAsync, Source
from uamqp import errors, types # type: ignore
from uamqp import ReceiveClientAsync, Source # type: ignore

from azure.eventhub import EventData, EventPosition
from azure.eventhub.error import EventHubError, ConnectError, _error_handler
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
import time
import logging

from uamqp import errors, compat
from uamqp import errors, compat # type: ignore
from ..error import EventHubError, EventDataSendError, \
EventDataError, ConnectError, ConnectionLostError, AuthenticationError

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,8 @@
from typing import Iterable, Union
import time

from uamqp import types, constants, errors
from uamqp import SendClientAsync
from uamqp import types, constants, errors # type: ignore
from uamqp import SendClientAsync # type: ignore

from azure.eventhub.common import EventData, EventDataBatch
from azure.eventhub.error import _error_handler, OperationTimeoutError, EventDataError
Expand Down
2 changes: 1 addition & 1 deletion sdk/eventhub/azure-eventhubs/azure/eventhub/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import datetime
import functools
try:
from urlparse import urlparse
from urlparse import urlparse # type: ignore
from urllib import unquote_plus, urlencode, quote_plus # type: ignore
except ImportError:
from urllib.parse import urlparse, unquote_plus, urlencode, quote_plus
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
from abc import abstractmethod
from typing import Dict
try:
from urlparse import urlparse
from urlparse import urlparse # type: ignore
from urllib import unquote_plus, urlencode, quote_plus # type: ignore
except ImportError:
from urllib.parse import urlparse, unquote_plus, urlencode, quote_plus
Expand All @@ -22,7 +22,7 @@
except ImportError:
TYPE_CHECKING = False
if TYPE_CHECKING:
from azure.core.credentials import TokenCredential
from azure.core.credentials import TokenCredential # type: ignore
from typing import Union, Any

from azure.eventhub import __version__
Expand Down
4 changes: 2 additions & 2 deletions sdk/eventhub/azure-eventhubs/azure/eventhub/consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@
import time
from typing import List

from uamqp import types, errors
from uamqp import ReceiveClient, Source
from uamqp import types, errors # type: ignore
from uamqp import ReceiveClient, Source # type: ignore

from azure.eventhub.common import EventData, EventPosition
from azure.eventhub.error import _error_handler
Expand Down
4 changes: 2 additions & 2 deletions sdk/eventhub/azure-eventhubs/azure/eventhub/producer.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@
import time
from typing import Iterable, Union

from uamqp import types, constants, errors
from uamqp import SendClient
from uamqp import types, constants, errors # type: ignore
from uamqp import SendClient # type: ignore

from azure.eventhub.common import EventData, EventDataBatch
from azure.eventhub.error import _error_handler, OperationTimeoutError, EventDataError
Expand Down