[Storage] Data Lake Typing and API View Feedback (Azure#40096)

Author: weirongw23-msft

sdk/storage/azure-storage-blob/CHANGELOG.md

@@ -1,8 +1,9 @@
 # Release History
 
-## 12.26.0b1 (Unreleased)
+## 12.25.1 (Unreleased)
 
-### Features Added
+### Other Changes
+- Updated dependency for `azure-storage-file-datalake` type hints.
 
 ## 12.25.0 (2025-03-11)
 

sdk/storage/azure-storage-blob/azure/storage/blob/_version.py

@@ -4,4 +4,4 @@
 # license information.
 # --------------------------------------------------------------------------
 
-VERSION = "12.26.0b1"
+VERSION = "12.25.1"

sdk/storage/azure-storage-blob/setup.py

@@ -56,7 +56,7 @@
     url='https://github.com/Azure/azure-sdk-for-python/tree/main/sdk/storage/azure-storage-blob',
     keywords="azure, azure sdk",
     classifiers=[
-        'Development Status :: 4 - Beta',
+        'Development Status :: 5 - Production/Stable',
         'Programming Language :: Python',
         'Programming Language :: Python :: 3 :: Only',
         'Programming Language :: Python :: 3',

sdk/storage/azure-storage-file-datalake/CHANGELOG.md

@@ -1,8 +1,9 @@
 # Release History
 
-## 12.20.0b1 (Unreleased)
+## 12.20.0 (Unreleased)
 
 ### Features Added
+- Updated type hints across the entire package and enabled MyPy to run during CI. Some public types may have been adjusted if they were previously erroneous or incomplete.
 
 ## 12.19.0 (2025-03-11)
 

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_data_lake_directory_client.py

@@ -227,7 +227,7 @@ def create_directory(
         return self._create('directory', metadata=metadata, **kwargs)
 
     @distributed_trace
-    def delete_directory(self, **kwargs: Any) -> Dict[str, Any]:  # pylint: disable=delete-operation-wrong-return-type
+    def delete_directory(self, **kwargs: Any) -> None:
         """
         Marks the specified directory for deletion.
 
@@ -270,7 +270,7 @@ def delete_directory(self, **kwargs: Any) -> Dict[str, Any]:  # pylint: disable=
                 :dedent: 4
                 :caption: Delete directory.
         """
-        return self._delete(recursive=True, **kwargs)
+        return self._delete(recursive=True, **kwargs)  # type: ignore [return-value]
 
     @distributed_trace
     def get_directory_properties(self, **kwargs: Any) -> DirectoryProperties:

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_data_lake_file_client.py

@@ -7,7 +7,7 @@
 
 from datetime import datetime
 from typing import (
-    Any, AnyStr, AsyncIterable, cast, Dict, IO, Iterable, Optional, Union,
+    Any, AnyStr, cast, Dict, IO, Iterable, Optional, Union,
     TYPE_CHECKING
 )
 from urllib.parse import quote, unquote
@@ -240,7 +240,7 @@ def create_file(
         return self._create('file', content_settings=content_settings, metadata=metadata, **kwargs)
 
     @distributed_trace
-    def delete_file(self, **kwargs: Any) -> Dict[str, Any]:  # pylint: disable=delete-operation-wrong-return-type
+    def delete_file(self, **kwargs: Any) -> None:
         """
         Marks the specified file for deletion.
 
@@ -271,8 +271,8 @@ def delete_file(self, **kwargs: Any) -> Dict[str, Any]:  # pylint: disable=delet
             This value is not tracked or validated on the client. To configure client-side network timesouts
             see `here <https://github.com/Azure/azure-sdk-for-python/tree/main/sdk/storage/azure-storage-file-datalake
             #other-client--per-operation-configuration>`_.
-        :returns: A dictionary of response headers.
-        :rtype: Dict[str, Any]
+        :returns: A dictionary of response headers or None.
+        :rtype: Dict[str, Any] or None
 
         .. admonition:: Example:
 
@@ -283,7 +283,7 @@ def delete_file(self, **kwargs: Any) -> Dict[str, Any]:  # pylint: disable=delet
                 :dedent: 4
                 :caption: Delete file.
         """
-        return self._delete(**kwargs)
+        return self._delete(**kwargs)  # type: ignore [return-value]
 
     @distributed_trace
     def get_file_properties(self, **kwargs: Any) -> FileProperties:
@@ -379,7 +379,7 @@ def set_file_expiry(
 
     @distributed_trace
     def upload_data(
-        self, data: Union[bytes, str, Iterable[AnyStr], AsyncIterable[AnyStr], IO[AnyStr]],
+        self, data: Union[bytes, str, Iterable[AnyStr], IO[AnyStr]],
         length: Optional[int] = None,
         overwrite: Optional[bool] = False,
         **kwargs: Any
@@ -388,7 +388,7 @@ def upload_data(
         Upload data to a file.
 
         :param data: Content to be uploaded to file
-        :type data: bytes, str, Iterable[AnyStr], AsyncIterable[AnyStr], or IO[AnyStr]
+        :type data: bytes, str, Iterable[AnyStr], or IO[AnyStr]
         :param int length: Size of the data in bytes.
         :param bool overwrite: to overwrite an existing file or not.
         :keyword ~azure.storage.filedatalake.ContentSettings content_settings:

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_data_lake_lease.py

@@ -60,7 +60,7 @@ def __init__(  # pylint: disable=missing-client-constructor-parameter-credential
         elif hasattr(client, '_container_client'):
             _client = client._container_client
         else:
-            raise TypeError("Lease must use any of FileSystemClient DataLakeDirectoryClient, or DataLakeFileClient.")
+            raise TypeError("Lease must use any of FileSystemClient, DataLakeDirectoryClient, or DataLakeFileClient.")
 
         self._blob_lease_client = BlobLeaseClient(_client, lease_id=lease_id)
 

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_version.py

@@ -4,4 +4,4 @@
 # license information.
 # --------------------------------------------------------------------------
 
-VERSION = "12.20.0b1"
+VERSION = "12.20.0"

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/aio/_data_lake_directory_client_async.py

@@ -248,7 +248,7 @@ async def exists(self, **kwargs: Any) -> bool:
         return await self._exists(**kwargs)
 
     @distributed_trace_async
-    async def delete_directory(self, **kwargs: Any) -> Dict[str, Any]:
+    async def delete_directory(self, **kwargs: Any) -> None:
         """
         Marks the specified directory for deletion.
 
@@ -291,7 +291,7 @@ async def delete_directory(self, **kwargs: Any) -> Dict[str, Any]:
                 :dedent: 4
                 :caption: Delete directory.
         """
-        return await self._delete(recursive=True, **kwargs)
+        return await self._delete(recursive=True, **kwargs)  # type: ignore [return-value]
 
     @distributed_trace_async
     async def get_directory_properties(self, **kwargs: Any) -> DirectoryProperties:

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/aio/_data_lake_file_client_async.py

@@ -7,7 +7,7 @@
 
 from datetime import datetime
 from typing import (
-    Any, AnyStr, AsyncIterable, cast, Dict, IO, Iterable, Optional, Union,
+    Any, AnyStr, AsyncIterable, cast, Dict, IO, Optional, Union,
     TYPE_CHECKING
 )
 from urllib.parse import quote, unquote
@@ -256,7 +256,7 @@ async def exists(self, **kwargs: Any) -> bool:
         return await self._exists(**kwargs)
 
     @distributed_trace_async
-    async def delete_file(self, **kwargs: Any) -> Dict[str, Any]:
+    async def delete_file(self, **kwargs: Any) -> None:
         """
         Marks the specified file for deletion.
 
@@ -299,7 +299,7 @@ async def delete_file(self, **kwargs: Any) -> Dict[str, Any]:
                 :dedent: 4
                 :caption: Delete file.
         """
-        return await self._delete(**kwargs)
+        return await self._delete(**kwargs)  # type: ignore [return-value]
 
     @distributed_trace_async
     async def get_file_properties(self, **kwargs: Any) -> FileProperties:
@@ -395,7 +395,7 @@ async def set_file_expiry(
 
     @distributed_trace_async
     async def upload_data(
-        self, data: Union[bytes, str, Iterable[AnyStr], AsyncIterable[AnyStr], IO[AnyStr]],
+        self, data: Union[bytes, str, AsyncIterable[AnyStr], IO[AnyStr]],
         length: Optional[int] = None,
         overwrite: Optional[bool] = False,
         **kwargs: Any
@@ -404,7 +404,7 @@ async def upload_data(
         Upload data to a file.
 
         :param data: Content to be uploaded to file
-        :type data: bytes, str, Iterable[AnyStr], AsyncIterable[AnyStr], or IO[AnyStr]
+        :type data: bytes, str, AsyncIterable[AnyStr], or IO[AnyStr]
         :param int length: Size of the data in bytes.
         :param bool overwrite: to overwrite an existing file or not.
         :keyword ~azure.storage.filedatalake.ContentSettings content_settings:
@@ -489,15 +489,15 @@ async def upload_data(
 
     @distributed_trace_async
     async def append_data(
-        self, data: Union[bytes, str, Iterable[AnyStr], IO[AnyStr]],
+        self, data: Union[bytes, str, AsyncIterable[AnyStr], IO[AnyStr]],
         offset: int,
         length: Optional[int] = None,
         **kwargs: Any
     ) -> Dict[str, Any]:
         """Append data to the file.
 
         :param data: Content to be appended to file
-        :type data: bytes, str, Iterable[AnyStr], or IO[AnyStr]
+        :type data: bytes, str, AsyncIterable[AnyStr], or IO[AnyStr]
         :param int offset: start position of the data to be appended to.
         :param length: Size of the data in bytes.
         :type length: int or None