[EH] next-pylint (Azure#38896)

* eh pylint

* remove

* fix

* update

Author: l0lawrence

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

@@ -393,7 +393,7 @@ def _backoff(
         )
         if backoff <= self._config.backoff_max and (
             timeout_time is None or time.time() + backoff <= timeout_time
-        ):  # pylint:disable=no-else-return
+        ):
             time.sleep(backoff)
             _LOGGER.info(
                 "%r has an exception (%r). Retrying...",
@@ -411,7 +411,6 @@ def _backoff(
     def _management_request(  # pylint:disable=inconsistent-return-statements
         self, mgmt_msg: Union[uamqp_Message, Message], op_type: bytes
     ) -> Any:
-        # pylint:disable=assignment-from-none
         retried_times = 0
         last_exception = None
         while retried_times <= self._config.max_retries:
@@ -420,7 +419,7 @@ def _management_request(  # pylint:disable=inconsistent-return-statements
                 self._address, mgmt_auth=mgmt_auth, config=self._config
             )
             try:
-                conn = self._conn_manager.get_connection(  # pylint:disable=assignment-from-none
+                conn = self._conn_manager.get_connection(
                     endpoint=self._address.hostname, auth=mgmt_auth
                 )
                 mgmt_client.open(connection=conn)

sdk/eventhub/azure-eventhub/azure/eventhub/_common.py

@@ -59,7 +59,7 @@
 
 if TYPE_CHECKING:
     try:
-        from uamqp import (  # pylint: disable=unused-import
+        from uamqp import (
             Message,  # not importing as uamqp_Message, b/c type is exposed to user
             BatchMessage,
         )
@@ -143,7 +143,6 @@ def __init__(
         self.correlation_id = None
 
     def __repr__(self) -> str:
-        # pylint: disable=bare-except
         try:
             body_str = self.body_as_str()
         except Exception as e:  # pylint: disable=broad-except
@@ -230,7 +229,6 @@ def _from_message(
         message: Union["Message", pyamqp_Message],
         raw_amqp_message: Optional[AmqpAnnotatedMessage] = None,
     ) -> EventData:
-        # pylint:disable=protected-access
         """Internal use only.
 
         Creates an EventData object from a raw uamqp message and, if provided, AmqpAnnotatedMessage.
@@ -242,13 +240,11 @@ def _from_message(
         :rtype: ~azure.eventhub.EventData
         """
         event_data = cls(body="")
-        # pylint: disable=protected-access
         event_data._message = message
         event_data._raw_amqp_message = raw_amqp_message if raw_amqp_message else AmqpAnnotatedMessage(message=message)
         return event_data
 
     def _decode_non_data_body_as_str(self, encoding: str = "UTF-8") -> str:
-        # pylint: disable=protected-access
         body = self.raw_amqp_message.body
         if self.body_type == AmqpMessageBodyType.VALUE:
             if not body:

sdk/eventhub/azure-eventhub/azure/eventhub/_consumer.py

@@ -111,7 +111,7 @@ def __init__(self, client: "EventHubConsumerClient", source: str, **kwargs: Any)
         if owner_level is not None:
             link_properties[EPOCH_SYMBOL] = int(owner_level)
         link_property_timeout_ms = (
-            self._client._config.receive_timeout or self._timeout  # pylint:disable=protected-access
+            self._client._config.receive_timeout or self._timeout
         ) * self._amqp_transport.TIMEOUT_FACTOR
         link_properties[TIMEOUT_SYMBOL] = int(link_property_timeout_ms)
         self._link_properties: Union[Dict[uamqp_AMQPType, uamqp_AMQPType], Dict[types.AMQPTypes, types.AMQPTypes]] = (
@@ -158,7 +158,6 @@ def _open_with_retry(self) -> None:
         self._do_retryable_operation(self._open, operation_need_param=False)
 
     def _message_received(self, message: Union[uamqp_Message, Message]) -> None:
-        # pylint:disable=protected-access
         self._message_buffer.append(message)
 
     def _next_message_in_buffer(self):
@@ -245,7 +244,7 @@ def receive(self, batch=False, max_batch_size=300, max_wait_time=None):
             if batch:
                 events_for_callback = []
                 for _ in range(min(max_batch_size, len(self._message_buffer))):
-                    events_for_callback.append(self._next_message_in_buffer())  # pylint: disable=protected-access
+                    events_for_callback.append(self._next_message_in_buffer())
                 self._on_event_received(events_for_callback)
             else:
                 self._on_event_received(self._next_message_in_buffer() if self._message_buffer else None)

sdk/eventhub/azure-eventhub/azure/eventhub/_eventprocessor/_eventprocessor_mixin.py

@@ -18,7 +18,6 @@
 )
 
 if TYPE_CHECKING:
-    # pylint: disable=ungrouped-imports
     from .._common import EventData
     from .._consumer import EventHubConsumer
     from ..aio._consumer_async import EventHubConsumer as EventHubConsumerAsync

sdk/eventhub/azure-eventhub/azure/eventhub/_eventprocessor/event_processor.py

@@ -78,10 +78,9 @@ def __init__(
         prefetch: Optional[int] = None,
         track_last_enqueued_event_properties: bool = False,
     ) -> None:
-        # pylint: disable=line-too-long
         self._consumer_group = consumer_group
         self._eventhub_client = eventhub_client
-        self._namespace = eventhub_client._address.hostname  # pylint: disable=protected-access
+        self._namespace = eventhub_client._address.hostname
         self._eventhub_name = eventhub_client.eventhub_name
         self._event_handler = on_event
         self._batch = batch
@@ -240,7 +239,7 @@ def _on_event_received(
 
             with receive_context_manager(
                 self._eventhub_client, links=links, start_time=self._last_received_time
-            ):  # pylint:disable=protected-access
+            ):
                 self._last_received_time = time.time_ns()
 
             with process_context_manager(self._eventhub_client, links=links, is_batch=is_batch):

sdk/eventhub/azure-eventhub/azure/eventhub/_eventprocessor/ownership_manager.py

@@ -41,7 +41,7 @@ def __init__(
         self.cached_parition_ids: List[str] = []
         self.owned_partitions: Iterable[Dict[str, Any]] = []
         self.eventhub_client = eventhub_client
-        self.fully_qualified_namespace = eventhub_client._address.hostname  # pylint: disable=protected-access
+        self.fully_qualified_namespace = eventhub_client._address.hostname
         self.eventhub_name = eventhub_client.eventhub_name
         self.consumer_group = consumer_group
         self.owner_id = owner_id

sdk/eventhub/azure-eventhub/azure/eventhub/_producer.py

@@ -264,7 +264,7 @@ def send(
                     links = [link] if link else []
 
             self._unsent_events = [wrapper_event_data._message]  # pylint: disable=protected-access
-            with send_context_manager(self._client, links=links):  # pylint: disable=protected-access
+            with send_context_manager(self._client, links=links):
                 self._send_event_data_with_retry(timeout=timeout)
 
     def close(self) -> None:

sdk/eventhub/azure-eventhub/azure/eventhub/_producer_client.py

@@ -319,7 +319,7 @@ def _buffered_send_event(
         timeout: Optional[float] = None,
         partition_id: Optional[str] = None,
         partition_key: Optional[str] = None,
-        **kwargs: Any,  # pylint: disable=unused-argument
+        **kwargs: Any,
     ) -> None:
         set_event_partition_key(event, partition_key, self._amqp_transport)
         timeout_time = time.time() + timeout if timeout else None
@@ -565,7 +565,7 @@ def send_event(
         timeout: Optional[float] = None,
         partition_id: Optional[str] = None,
         partition_key: Optional[str] = None,
-        **kwargs: Any,  # pylint: disable=unused-argument
+        **kwargs: Any,
     ) -> None:
         """
         Sends an event data.

sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_connection.py

@@ -42,7 +42,7 @@
 )
 
 
-def get_local_timeout(now: float, idle_timeout: Optional[float], last_frame_received_time: float) -> bool:
+def get_local_timeout(now: float, idle_timeout: float, last_frame_received_time: float) -> bool:
     """Check whether the local timeout has been reached since a new incoming frame was received.
 
     :param float now: The current time to check against.
@@ -90,7 +90,7 @@ class Connection:  # pylint:disable=too-many-instance-attributes
      and 1 for transport type AmqpOverWebsocket.
     """
 
-    def __init__(  # pylint:disable=too-many-locals,too-many-statements
+    def __init__(  # pylint:disable=too-many-locals
         self,
         endpoint: str,
         *,

sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_decode.py

@@ -3,8 +3,6 @@
 # Licensed under the MIT License. See License.txt in the project root for
 # license information.
 # --------------------------------------------------------------------------
-# pylint: disable=redefined-builtin, import-error
-
 import struct
 import uuid
 import logging