Linting blob extension (#18)

* black

* isort

* weird import ordering

---------

Co-authored-by: Victoria Hall <[email protected]>

Author: hallvictoria

azure-functions-extension-blob/azure/functions/extension/blob/__init__.py

@@ -2,14 +2,15 @@
 #  Licensed under the MIT License.
 
 from .blobClient import BlobClient
+from .blobClientConverter import BlobClientConverter
 from .containerClient import ContainerClient
 from .storageStreamDownloader import StorageStreamDownloader
-from .blobClientConverter import BlobClientConverter
 
 __all__ = [
-    'BlobClient',
-    'ContainerClient',
-    'StorageStreamDownloader',
-    'BlobClientConverter']
+    "BlobClient",
+    "ContainerClient",
+    "StorageStreamDownloader",
+    "BlobClientConverter",
+]
 
 __version__ = "1.0.0a1"

azure-functions-extension-blob/azure/functions/extension/blob/blobClient.py

@@ -3,10 +3,10 @@
 
 import json
 import os
+from typing import Union
 
 from azure.functions.extension.base import Datum, SdkType
 from azure.storage.blob import BlobClient as BlobClientSdk
-from typing import Union
 
 
 class BlobClient(SdkType):
@@ -35,7 +35,7 @@ def get_sdk_type(self):
             return BlobClientSdk.from_connection_string(
                 conn_str=self._connection,
                 container_name=self._containerName,
-                blob_name=self._blobName
+                blob_name=self._blobName,
             )
         else:
             return None

azure-functions-extension-blob/azure/functions/extension/blob/blobClientConverter.py

@@ -4,20 +4,24 @@
 from typing import Any
 
 from azure.functions.extension.base import Datum, InConverter, OutConverter
+
 from .blobClient import BlobClient
 from .containerClient import ContainerClient
 from .storageStreamDownloader import StorageStreamDownloader
 
 
-class BlobClientConverter(InConverter,
-                          OutConverter,
-                          binding='blob',
-                          trigger='blobTrigger',):
+class BlobClientConverter(
+    InConverter,
+    OutConverter,
+    binding="blob",
+    trigger="blobTrigger",
+):
 
     @classmethod
     def check_input_type_annotation(cls, pytype: type) -> bool:
-        return issubclass(pytype, (BlobClient, ContainerClient,
-                                   StorageStreamDownloader))
+        return issubclass(
+            pytype, (BlobClient, ContainerClient, StorageStreamDownloader)
+        )
 
     @classmethod
     def decode(cls, data: Datum, *, trigger_metadata, pytype) -> Any:
@@ -26,12 +30,12 @@ def decode(cls, data: Datum, *, trigger_metadata, pytype) -> Any:
 
         data_type = data.type
 
-        if data_type == 'model_binding_data':
+        if data_type == "model_binding_data":
             data = data.value
         else:
             raise ValueError(
                 f'unexpected type of data received for the "blob" binding '
-                f': {data_type!r}'
+                f": {data_type!r}"
             )
 
         # Determines which sdk type to return based on pytype

azure-functions-extension-blob/azure/functions/extension/blob/containerClient.py

@@ -3,10 +3,10 @@
 
 import json
 import os
+from typing import Union
 
 from azure.functions.extension.base import Datum, SdkType
 from azure.storage.blob import ContainerClient as ContainerClientSdk
-from typing import Union
 
 
 class ContainerClient(SdkType):
@@ -33,8 +33,7 @@ def __init__(self, *, data: Union[bytes, Datum]) -> None:
     def get_sdk_type(self):
         if self._data:
             return ContainerClientSdk.from_connection_string(
-                conn_str=self._connection,
-                container_name=self._containerName
+                conn_str=self._connection, container_name=self._containerName
             )
         else:
             return None

azure-functions-extension-blob/azure/functions/extension/blob/storageStreamDownloader.py

@@ -3,10 +3,10 @@
 
 import json
 import os
+from typing import Union
 
 from azure.functions.extension.base import Datum, SdkType
 from azure.storage.blob import BlobClient as BlobClientSdk
-from typing import Union
 
 
 class StorageStreamDownloader(SdkType):
@@ -36,7 +36,8 @@ def get_sdk_type(self):
             blob_client = BlobClientSdk.from_connection_string(
                 conn_str=self._connection,
                 container_name=self._containerName,
-                blob_name=self._blobName)
+                blob_name=self._blobName,
+            )
             # download_blob() returns a StorageStreamDownloader object
             return blob_client.download_blob()
         else:

azure-functions-extension-blob/samples/blob_samples_blobclient/function_app.py

@@ -7,6 +7,7 @@
 # --------------------------------------------------------------------------
 
 import logging
+
 import azure.functions as func
 import azure.functions.extension.blob as blob
 
@@ -27,21 +28,25 @@
 """
 
 
-@app.blob_trigger(arg_name="client",
-                  path="PATH/TO/BLOB",
-                  connection="AzureWebJobsStorage")
+@app.blob_trigger(
+    arg_name="client", path="PATH/TO/BLOB", connection="AzureWebJobsStorage"
+)
 def blob_trigger(client: blob.BlobClient):
-    logging.info(f"Python blob trigger function processed blob \n"
-                 f"Properties: {client.get_blob_properties()}\n"
-                 f"Blob content: {client.download_blob().readall()}")
+    logging.info(
+        f"Python blob trigger function processed blob \n"
+        f"Properties: {client.get_blob_properties()}\n"
+        f"Blob content: {client.download_blob().readall()}"
+    )
 
 
 @app.route(route="file")
-@app.blob_input(arg_name="client",
-                path="PATH/TO/BLOB",
-                connection="AzureWebJobsStorage")
+@app.blob_input(
+    arg_name="client", path="PATH/TO/BLOB", connection="AzureWebJobsStorage"
+)
 def blob_input(req: func.HttpRequest, client: blob.BlobClient):
-    logging.info(f"Python blob trigger function processed blob \n"
-                 f"Properties: {client.get_blob_properties()}\n"
-                 f"Blob content: {client.download_blob().readall()}")
+    logging.info(
+        f"Python blob trigger function processed blob \n"
+        f"Properties: {client.get_blob_properties()}\n"
+        f"Blob content: {client.download_blob().readall()}"
+    )
     return "ok"

azure-functions-extension-blob/samples/blob_samples_containerclient/function_app.py

@@ -7,6 +7,7 @@
 # --------------------------------------------------------------------------
 
 import logging
+
 import azure.functions as func
 import azure.functions.extension.blob as blob
 
@@ -27,19 +28,19 @@
 """
 
 
-@app.blob_trigger(arg_name="client",
-                  path="CONTAINER",
-                  connection="AzureWebJobsStorage")
+@app.blob_trigger(arg_name="client", path="CONTAINER", connection="AzureWebJobsStorage")
 def blob_trigger(client: blob.ContainerClient):
-    logging.info(f"Python blob trigger function processed blob \n"
-                 f"Properties: {client.get_container_properties()}\n")
+    logging.info(
+        f"Python blob trigger function processed blob \n"
+        f"Properties: {client.get_container_properties()}\n"
+    )
 
 
 @app.route(route="file")
-@app.blob_input(arg_name="client",
-                path="CONTAINER",
-                connection="AzureWebJobsStorage")
+@app.blob_input(arg_name="client", path="CONTAINER", connection="AzureWebJobsStorage")
 def blob_input(req: func.HttpRequest, client: blob.BlobClient):
-    logging.info(f"Python blob trigger function processed blob \n"
-                 f"Properties: {client.get_container_properties()}\n")
+    logging.info(
+        f"Python blob trigger function processed blob \n"
+        f"Properties: {client.get_container_properties()}\n"
+    )
     return "ok"

azure-functions-extension-blob/samples/blob_samples_storagestreamdownloader/function_app.py

@@ -7,6 +7,7 @@
 # --------------------------------------------------------------------------
 
 import logging
+
 import azure.functions as func
 import azure.functions.extension.blob as blob
 
@@ -27,21 +28,25 @@
 """
 
 
-@app.blob_trigger(arg_name="stream",
-                  path="PATH/TO/BLOB",
-                  connection="AzureWebJobsStorage")
+@app.blob_trigger(
+    arg_name="stream", path="PATH/TO/BLOB", connection="AzureWebJobsStorage"
+)
 def blob_trigger(stream: blob.StorageStreamDownloader):
     for chunk in stream.chunks():
-        logging.info(f"Python blob trigger function processed blob chunk \n"
-                     f"Chunk: {chunk.decode()}")
+        logging.info(
+            f"Python blob trigger function processed blob chunk \n"
+            f"Chunk: {chunk.decode()}"
+        )
 
 
 @app.route(route="file")
-@app.blob_input(arg_name="stream",
-                path="PATH/TO/BLOB",
-                connection="AzureWebJobsStorage")
+@app.blob_input(
+    arg_name="stream", path="PATH/TO/BLOB", connection="AzureWebJobsStorage"
+)
 def blob_input(req: func.HttpRequest, stream: blob.StorageStreamDownloader):
     for chunk in stream.chunks():
-        logging.info(f"Python blob trigger function processed blob chunk \n"
-                     f"Chunk: {chunk.decode()}")
+        logging.info(
+            f"Python blob trigger function processed blob chunk \n"
+            f"Chunk: {chunk.decode()}"
+        )
     return "ok"

azure-functions-extension-blob/tests/__init__.py

@@ -11,11 +11,10 @@
 
 def suite():
     test_loader = unittest.TestLoader()
-    return test_loader.discover(
-        os.path.dirname(__file__), pattern='test_*.py')
+    return test_loader.discover(os.path.dirname(__file__), pattern="test_*.py")
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     runner = unittest.runner.TextTestRunner()
     result = runner.run(suite())
     sys.exit(not result.wasSuccessful())