[ServiceBus&EventHubs] fix mypy 0.931 errors

sdk/eventhub/azure-eventhub/azure/eventhub/_client_base.py

@@ -46,7 +46,7 @@
     from azure.core.credentials import TokenCredential
 
 _LOGGER = logging.getLogger(__name__)
-_Address = collections.namedtuple("Address", "hostname path")
+_Address = collections.namedtuple("_Address", "hostname path")
 
 
 def _parse_conn_str(conn_str, **kwargs):

sdk/servicebus/azure-servicebus/azure/servicebus/_servicebus_receiver.py

@@ -8,7 +8,7 @@
 import uuid
 import datetime
 import warnings
-from typing import Any, List, Optional, Dict, Iterator, Union, TYPE_CHECKING
+from typing import Any, List, Optional, Dict, Iterator, Union, TYPE_CHECKING, cast
 
 import six
 
@@ -692,6 +692,7 @@ def receive_deferred_messages(
             raise ValueError("The timeout must be greater than 0.")
         if isinstance(sequence_numbers, six.integer_types):
             sequence_numbers = [sequence_numbers]
+        sequence_numbers = cast(List[int], sequence_numbers)
         if len(sequence_numbers) == 0:
             return []  # no-op on empty list.
         self._open()

sdk/servicebus/azure-servicebus/azure/servicebus/aio/_servicebus_receiver_async.py

@@ -8,7 +8,7 @@
 import functools
 import logging
 import warnings
-from typing import Any, List, Optional, AsyncIterator, Union, Callable, TYPE_CHECKING
+from typing import Any, List, Optional, AsyncIterator, Union, Callable, TYPE_CHECKING, cast
 
 import six
 
@@ -678,6 +678,7 @@ async def receive_deferred_messages(
             raise ValueError("The timeout must be greater than 0.")
         if isinstance(sequence_numbers, six.integer_types):
             sequence_numbers = [sequence_numbers]
+        sequence_numbers = cast(List[int], sequence_numbers)
         if len(sequence_numbers) == 0:
             return []  # no-op on empty list.
         await self._open()