Some final tweaks (#6687)

* Some final tweaks

* oops

* comments

* little better

* Pylint

Author: Rakshith Bhyravabhotla

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

@@ -197,9 +197,9 @@ def format_shared_key_credential(account, credential):
 
 def parse_connection_str(conn_str, credential, service):
     conn_str = conn_str.rstrip(";")
-    conn_settings = dict(
+    conn_settings = dict( # pylint: disable=consider-using-dict-comprehension
         [s.split("=", 1) for s in conn_str.split(";")]
-    )  # pylint: disable=consider-using-dict-comprehension
+    )
     endpoints = _SERVICE_PARAMS[service]
     primary = None
     secondary = None

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

@@ -465,7 +465,10 @@ def download_to_stream(self, stream, max_connections=1):
         if max_connections > 1:
             import concurrent.futures
             executor = concurrent.futures.ThreadPoolExecutor(max_connections)
-            list(executor.map(tracing_context.with_current_context(downloader.process_chunk), downloader.get_chunk_offsets()))
+            list(executor.map(
+                    tracing_context.with_current_context(downloader.process_chunk),
+                    downloader.get_chunk_offsets()
+                ))
         else:
             for chunk in downloader.get_chunk_offsets():
                 downloader.process_chunk(chunk)

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

@@ -310,7 +310,11 @@ def list_containers(
             timeout=timeout,
             **kwargs)
         return AsyncItemPaged(
-            command, prefix=name_starts_with, results_per_page=results_per_page, page_iterator_class=ContainerPropertiesPaged)
+            command,
+            prefix=name_starts_with,
+            results_per_page=results_per_page,
+            page_iterator_class=ContainerPropertiesPaged
+        )
 
     async def create_container(
             self, name,  # type: str

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

@@ -511,7 +511,12 @@ def list_blobs(self, name_starts_with=None, include=None, timeout=None, **kwargs
             include=include,
             timeout=timeout,
             **kwargs)
-        return AsyncItemPaged(command, prefix=name_starts_with, results_per_page=results_per_page, page_iterator_class=BlobPropertiesPaged)
+        return AsyncItemPaged(
+            command,
+            prefix=name_starts_with,
+            results_per_page=results_per_page,
+            page_iterator_class=BlobPropertiesPaged
+        )
 
     def walk_blobs(
             self, name_starts_with=None, # type: Optional[str]

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

@@ -424,7 +424,11 @@ def list_containers(
             timeout=timeout,
             **kwargs)
         return ItemPaged(
-            command, prefix=name_starts_with, results_per_page=results_per_page, page_iterator_class=ContainerPropertiesPaged)
+                command,
+                prefix=name_starts_with,
+                results_per_page=results_per_page,
+                page_iterator_class=ContainerPropertiesPaged
+            )
 
     @distributed_trace
     def create_container(

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

@@ -44,8 +44,8 @@
 from .blob_client import BlobClient
 
 if TYPE_CHECKING:
-    from azure.core.pipeline.transport import HttpTransport
-    from azure.core.pipeline.policies import HTTPPolicy
+    from azure.core.pipeline.transport import HttpTransport  # pylint: disable=ungrouped-imports
+    from azure.core.pipeline.policies import HTTPPolicy # pylint: disable=ungrouped-imports
     from .models import ContainerPermissions, PublicAccess
     from datetime import datetime
     from .models import ( # pylint: disable=unused-import

sdk/storage/azure-storage-blob/tests/test_large_block_blob.py

@@ -9,6 +9,7 @@
 import pytest
 
 import os
+import platform
 import unittest
 
 from azure.storage.blob import (
@@ -36,7 +37,8 @@
 LARGE_BLOCK_SIZE = 6 * 1024 * 1024
 
 # ------------------------------------------------------------------------------
-
+if platform.python_implementation() == 'PyPy':
+    pytest.skip("Skip tests for Pypy", allow_module_level=True)
 
 class StorageLargeBlockBlobTest(StorageTestCase):
     def setUp(self):

sdk/storage/azure-storage-file/azure/storage/file/_shared/base_client.py

@@ -197,9 +197,9 @@ def format_shared_key_credential(account, credential):
 
 def parse_connection_str(conn_str, credential, service):
     conn_str = conn_str.rstrip(";")
-    conn_settings = dict(
+    conn_settings = dict( # pylint: disable=consider-using-dict-comprehension
         [s.split("=", 1) for s in conn_str.split(";")]
-    )  # pylint: disable=consider-using-dict-comprehension
+    )
     endpoints = _SERVICE_PARAMS[service]
     primary = None
     secondary = None

sdk/storage/azure-storage-file/azure/storage/file/_shared/downloads.py

@@ -465,7 +465,10 @@ def download_to_stream(self, stream, max_connections=1):
         if max_connections > 1:
             import concurrent.futures
             executor = concurrent.futures.ThreadPoolExecutor(max_connections)
-            list(executor.map(tracing_context.with_current_context(downloader.process_chunk), downloader.get_chunk_offsets()))
+            list(executor.map(
+                    tracing_context.with_current_context(downloader.process_chunk),
+                    downloader.get_chunk_offsets()
+                ))
         else:
             for chunk in downloader.get_chunk_offsets():
                 downloader.process_chunk(chunk)

sdk/storage/azure-storage-file/azure/storage/file/aio/file_client_async.py

@@ -728,4 +728,3 @@ async def close_handles(
 
         polling_method = CloseHandlesAsync(self._config.copy_polling_interval)
         return async_poller(command, start_close, None, polling_method)
-