pylint

Author: l0lawrence

sdk/eventgrid/azure-eventgrid/azure/eventgrid/_legacy/_publisher_client.py

@@ -237,6 +237,7 @@ def send(self, events: SendType, *, channel_name: Optional[str] = None, **kwargs
             raise HttpResponseError(response=response)
 
     def close(self) -> None:
+        """Closes the EventGridPublisherClient session."""
         self._client.close()
 
     def __enter__(self) -> "EventGridPublisherClient":

sdk/eventhub/azure-eventhub/azure/eventhub/aio/_async_utils.py

@@ -5,8 +5,6 @@
 # --------------------------------------------------------------------------
 import asyncio  # pylint:disable=do-not-import-asyncio
 import sys
-from asyncio import Semaphore  # pylint:disable=do-not-import-asyncio
-
 
 def get_dict_with_loop_if_needed(loop):
     if sys.version_info >= (3, 10):
@@ -17,7 +15,7 @@ def get_dict_with_loop_if_needed(loop):
     return {}
 
 
-async def semaphore_acquire_with_timeout(semaphore: Semaphore, timeout=None):
+async def semaphore_acquire_with_timeout(semaphore: asyncio.Semaphore, timeout=None):
     try:
         return await asyncio.wait_for(semaphore.acquire(), timeout=timeout)
     except asyncio.TimeoutError:

sdk/eventhub/azure-eventhub/azure/eventhub/aio/_buffered_producer/_buffered_producer_async.py

@@ -7,7 +7,6 @@
 import logging
 import queue
 import time
-from asyncio import Lock # pylint:disable=do-not-import-asyncio
 from typing import Optional, Callable, Awaitable, TYPE_CHECKING
 
 from .._producer_async import EventHubProducer
@@ -39,7 +38,7 @@ def __init__(
         self._max_buffer_len = max_buffer_length
         self._cur_buffered_len = 0
         self._producer: EventHubProducer = producer
-        self._lock = Lock()
+        self._lock = asyncio.Lock()
         self._max_wait_time = max_wait_time
         self._on_success = self.failsafe_callback(on_success)
         self._on_error = self.failsafe_callback(on_error)

sdk/servicebus/azure-servicebus/azure/servicebus/management/_shared_key_policy.py

@@ -17,7 +17,7 @@ class ServiceBusSharedKeyCredentialPolicy(SansIOHTTPPolicy):
     :param str name:
     """
 
-    def __init__(self, endpoint: str, credential: ServiceBusSharedKeyCredential, name: str):
+    def __init__(self, endpoint: str, credential: ServiceBusSharedKeyCredential, name: str) -> None:
         super(ServiceBusSharedKeyCredentialPolicy, self).__init__()
         self._credential = credential
         self._endpoint = endpoint

sdk/servicebus/azure-servicebus/azure/servicebus/management/_utils.py

@@ -281,7 +281,7 @@ def serialize_rule_key_values(entry_ele, rule_descripiton):
 
 
 # Helper functions for common parameter validation errors in the client.
-def _validate_entity_name_type(entity_name: str, display_name: str ="entity name") -> None:
+def _validate_entity_name_type(entity_name: str, display_name: str = "entity name") -> None:
     if not isinstance(entity_name, str):
         raise TypeError("{} must be a string, not {}".format(display_name, type(entity_name)))