lint

azure_functions_worker/bindings/meta.py

@@ -181,10 +181,10 @@ async def from_incoming_proto(
         # if the binding is an sdk type binding
         if is_deferred_binding:
             return await deferred_bindings_decode(binding=binding,
-                                            pb=pb,
-                                            pytype=pytype,
-                                            datum=datum,
-                                            metadata=metadata)
+                                                  pb=pb,
+                                                  pytype=pytype,
+                                                  datum=datum,
+                                                  metadata=metadata)
         return binding.decode(datum, trigger_metadata=metadata)
     except NotImplementedError:
         # Binding does not support the data.
@@ -278,10 +278,10 @@ def to_outgoing_param_binding(binding: str, obj: typing.Any, *,
 
 
 async def deferred_bindings_decode(binding: typing.Any,
-                             pb: protos.ParameterBinding, *,
-                             pytype: typing.Optional[type],
-                             datum: typing.Any,
-                             metadata: typing.Any):
+                                   pb: protos.ParameterBinding, *,
+                                   pytype: typing.Optional[type],
+                                   datum: typing.Any,
+                                   metadata: typing.Any):
     """
     This cache holds deferred binding types (ie. BlobClient, ContainerClient)
     That have already been created, so that the worker can reuse the
@@ -299,8 +299,8 @@ async def deferred_bindings_decode(binding: typing.Any,
                                             datum.value.content))
     else:
         deferred_binding_type = await binding.decode(datum,
-                                               trigger_metadata=metadata,
-                                               pytype=pytype)
+                                                     trigger_metadata=metadata,
+                                                     pytype=pytype)
         deferred_bindings_cache[(pb.name,
                                  pytype,
                                  datum.value.content)] = deferred_binding_type

tests/extension_tests/deferred_bindings_tests/deferred_bindings_blob_functions/function_app.py

@@ -296,7 +296,7 @@ async def aio_ssd(req: func.HttpRequest,
     decoded = file.decode('utf-8')
     return str(decoded)
 
-  
+
 @app.function_name(name="invalid_connection_info")
 @app.blob_input(arg_name="client",
                 path="python-worker-tests/test-blobclient-triggered.txt",

tests/extension_tests/deferred_bindings_tests/test_deferred_bindings_blob_functions.py

@@ -183,12 +183,16 @@ class TestDeferredBindingsBlobFunctions(testutils.WebHostTestCase):
     def test_aio_clients(self):
         r = self.webhost.request('GET', 'aio_blob_client')
         self.assertEqual(r.status_code, 200)
-        self.assertEqual(r.text, ('b\'{"name": "test-blobclient-trigger.txt", "length": 9, "content": '
-                                  '"DummyData"}\''))
+        self.assertEqual(r.text,
+                         ('b\'{"name": "test-blobclient-trigger.txt",'
+                          ' "length": 9, "content": '
+                          '"DummyData"}\''))
 
         r = self.webhost.request('GET', 'aio_container_client')
         self.assertEqual(r.status_code, 200)
-        self.assertEqual(r.text, '{\r\n  "name": "python-worker-tests",\r\n  "content": "DummyData"\r\n}')
+        self.assertEqual(r.text,
+                         '{\r\n  "name": "python-worker-tests",\r\n '
+                         '"content": "DummyData"\r\n}')
 
         r = self.webhost.request('GET', 'aio_ssd')
         self.assertEqual(r.status_code, 200)