[Storage] next-pylint April 25 (Azure#39839)

Author: weirongw23-msft

sdk/storage/azure-storage-blob/azure/storage/blob/_shared/avro/avro_io.py

@@ -162,11 +162,11 @@ def read_utf8(self):
             try:
                 return input_bytes.decode('utf-8')
             except UnicodeDecodeError as exn:
-                logger.error('Invalid UTF-8 input bytes: %r', input_bytes)
+                logger.error('Invalid UTF-8 input bytes: %r', input_bytes)  # pylint: disable=do-not-log-raised-errors
                 raise exn
         else:
             # PY2
-            return unicode(input_bytes, "utf-8") # pylint: disable=undefined-variable
+            return unicode(input_bytes, "utf-8")  # pylint: disable=undefined-variable
 
     def skip_null(self):
         pass

sdk/storage/azure-storage-blob/azure/storage/blob/_shared/avro/avro_io_async.py

@@ -145,7 +145,7 @@ async def read_utf8(self):
             try:
                 return input_bytes.decode('utf-8')
             except UnicodeDecodeError as exn:
-                logger.error('Invalid UTF-8 input bytes: %r', input_bytes)
+                logger.error('Invalid UTF-8 input bytes: %r', input_bytes)  # pylint: disable=do-not-log-raised-errors
                 raise exn
         else:
             # PY2

sdk/storage/azure-storage-blob/azure/storage/blob/_shared/policies_async.py

@@ -5,7 +5,7 @@
 # --------------------------------------------------------------------------
 # pylint: disable=invalid-overridden-method
 
-import asyncio
+import asyncio  # pylint: disable=do-not-import-asyncio
 import logging
 import random
 from typing import Any, Dict, TYPE_CHECKING

sdk/storage/azure-storage-blob/azure/storage/blob/_shared/request_handlers.py

@@ -136,8 +136,7 @@ def validate_and_format_range_headers(
     return range_header, range_validation
 
 
-def add_metadata_headers(metadata=None):
-    # type: (Optional[Dict[str, str]]) -> Dict[str, str]
+def add_metadata_headers(metadata: Optional[Dict[str, str]] = None) -> Dict[str, str]:
     headers = {}
     if metadata:
         for key, value in metadata.items():

sdk/storage/azure-storage-blob/azure/storage/blob/_shared/uploads_async.py

@@ -4,10 +4,9 @@
 # license information.
 # --------------------------------------------------------------------------
 
-import asyncio
+import asyncio  # pylint: disable=do-not-import-asyncio
 import inspect
 import threading
-from asyncio import Lock
 from io import UnsupportedOperation
 from itertools import islice
 from math import ceil
@@ -165,7 +164,7 @@ def __init__(
 
         # Progress feedback
         self.progress_total = 0
-        self.progress_lock = Lock() if parallel else None
+        self.progress_lock = asyncio.Lock() if parallel else None
         self.progress_hook = progress_hook
 
         # Encryption

sdk/storage/azure-storage-blob/azure/storage/blob/aio/_download_async.py

@@ -6,7 +6,7 @@
 # pylint: disable=invalid-overridden-method
 # mypy: disable-error-code=override
 
-import asyncio
+import asyncio  # pylint: disable=do-not-import-asyncio
 import codecs
 import sys
 import warnings

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_shared/policies_async.py

@@ -5,7 +5,7 @@
 # --------------------------------------------------------------------------
 # pylint: disable=invalid-overridden-method
 
-import asyncio
+import asyncio  # pylint: disable=do-not-import-asyncio
 import logging
 import random
 from typing import Any, Dict, TYPE_CHECKING

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_shared/request_handlers.py

@@ -136,8 +136,7 @@ def validate_and_format_range_headers(
     return range_header, range_validation
 
 
-def add_metadata_headers(metadata=None):
-    # type: (Optional[Dict[str, str]]) -> Dict[str, str]
+def add_metadata_headers(metadata: Optional[Dict[str, str]] = None) -> Dict[str, str]:
     headers = {}
     if metadata:
         for key, value in metadata.items():

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_shared/uploads_async.py

@@ -4,10 +4,9 @@
 # license information.
 # --------------------------------------------------------------------------
 
-import asyncio
+import asyncio  # pylint: disable=do-not-import-asyncio
 import inspect
 import threading
-from asyncio import Lock
 from io import UnsupportedOperation
 from itertools import islice
 from math import ceil
@@ -165,7 +164,7 @@ def __init__(
 
         # Progress feedback
         self.progress_total = 0
-        self.progress_lock = Lock() if parallel else None
+        self.progress_lock = asyncio.Lock() if parallel else None
         self.progress_hook = progress_hook
 
         # Encryption

sdk/storage/azure-storage-file-share/azure/storage/fileshare/_shared/policies_async.py

@@ -5,7 +5,7 @@
 # --------------------------------------------------------------------------
 # pylint: disable=invalid-overridden-method
 
-import asyncio
+import asyncio  # pylint: disable=do-not-import-asyncio
 import logging
 import random
 from typing import Any, Dict, TYPE_CHECKING