Azure · tasherif-msft · Oct 22, 2021 · Oct 21, 2021 · Oct 21, 2021 · Oct 21, 2021
@@ -49,6 +49,10 @@ def deserialize_path_properties(path_list):
     return [PathProperties._from_generated(path) for path in path_list] # pylint: disable=protected-access
 
 
+def return_headers_and_deserialized_path_list(response, deserialized, response_headers):  # pylint: disable=unused-argument
+    return deserialized.paths if deserialized.paths else {}, normalize_headers(response_headers)
+
+
 def get_deleted_path_properties_from_generated_code(generated):
     deleted_path = DeletedPathProperties()
     deleted_path.name = generated.name

@@ -20,15 +20,15 @@
 from azure.storage.blob import ContainerClient
 from ._shared.base_client import TransportWrapper, StorageAccountHostsMixin, parse_query, parse_connection_str
 from ._serialize import convert_dfs_url_to_blob_url, get_api_version
-from ._list_paths_helper import DeletedPathPropertiesPaged
+from ._list_paths_helper import DeletedPathPropertiesPaged, PathPropertiesPaged
 from ._models import LocationMode, FileSystemProperties, PublicAccess, DeletedPathProperties, FileProperties, \
     DirectoryProperties
 from ._data_lake_file_client import DataLakeFileClient
 from ._data_lake_directory_client import DataLakeDirectoryClient
 from ._data_lake_lease import DataLakeLeaseClient
 from ._generated import AzureDataLakeStorageRESTAPI
 from ._generated.models import ListBlobsIncludeItem
-from ._deserialize import deserialize_path_properties, process_storage_error, is_file_path
+from ._deserialize import process_storage_error, is_file_path
 
 
 ClassType = TypeVar("ClassType")
@@ -516,13 +516,14 @@ def get_paths(self, path=None, # type: Optional[str]
                 :caption: List the paths in the file system.
         """
         timeout = kwargs.pop('timeout', None)
-        return self._client.file_system.list_paths(
-            recursive=recursive,
-            max_results=max_results,
+        command = functools.partial(
+            self._client.file_system.list_paths,
             path=path,
             timeout=timeout,
-            cls=deserialize_path_properties,
             **kwargs)
+        return ItemPaged(
+            command, recursive, path=path, max_results=max_results,
+            page_iterator_class=PathPropertiesPaged, **kwargs)
 
     def create_directory(self, directory,  # type: Union[DirectoryProperties, str]
                          metadata=None,  # type: Optional[Dict[str, str]]

@@ -33,7 +33,7 @@ class AzureDataLakeStorageRESTAPI(object):
     :vartype file_system: azure.storage.filedatalake.operations.FileSystemOperations
     :ivar path: PathOperations operations
     :vartype path: azure.storage.filedatalake.operations.PathOperations
-    :param url: The URL of the service account, container, or blob that is the targe of the desired operation.
+    :param url: The URL of the service account, container, or blob that is the target of the desired operation.
     :type url: str
     """
 

@@ -23,7 +23,7 @@ class AzureDataLakeStorageRESTAPIConfiguration(Configuration):
     Note that all parameters used to create this instance are saved as instance
     attributes.
 
-    :param url: The URL of the service account, container, or blob that is the targe of the desired operation.
+    :param url: The URL of the service account, container, or blob that is the target of the desired operation.
     :type url: str
     """
 

@@ -28,7 +28,7 @@ class AzureDataLakeStorageRESTAPI(object):
     :vartype file_system: azure.storage.filedatalake.aio.operations.FileSystemOperations
     :ivar path: PathOperations operations
     :vartype path: azure.storage.filedatalake.aio.operations.PathOperations
-    :param url: The URL of the service account, container, or blob that is the targe of the desired operation.
+    :param url: The URL of the service account, container, or blob that is the target of the desired operation.
     :type url: str
     """
 

@@ -19,7 +19,7 @@ class AzureDataLakeStorageRESTAPIConfiguration(Configuration):
     Note that all parameters used to create this instance are saved as instance
     attributes.
 
-    :param url: The URL of the service account, container, or blob that is the targe of the desired operation.
+    :param url: The URL of the service account, container, or blob that is the target of the desired operation.
     :type url: str
     """
 

@@ -47,7 +47,7 @@ def list_file_systems(
         max_results: Optional[int] = None,
         request_id_parameter: Optional[str] = None,
         timeout: Optional[int] = None,
-        **kwargs
+        **kwargs: Any
     ) -> AsyncIterable["_models.FileSystemList"]:
         """List FileSystems.
 
@@ -68,8 +68,9 @@ def list_file_systems(
          limit that is recorded in the analytics logs when storage analytics logging is enabled.
         :type request_id_parameter: str
         :param timeout: The timeout parameter is expressed in seconds. For more information, see
-         :code:`<a href="https://docs.microsoft.com/en-us/rest/api/storageservices/fileservices/setting-
-         timeouts-for-blob-service-operations">Setting Timeouts for Blob Service Operations.</a>`.
+         :code:`<a
+         href="https://docs.microsoft.com/en-us/rest/api/storageservices/fileservices/setting-timeouts-for-blob-service-operations">Setting
+         Timeouts for Blob Service Operations.</a>`.
         :type timeout: int
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: An iterator like instance of either FileSystemList or the result of cls(response)