flake8

Author: YunchuWang

azure_functions_worker/bindings/meta.py

@@ -15,19 +15,21 @@
 PB_TYPE_RPC_SHARED_MEMORY = 'rpc_shared_memory'
 BINDING_REGISTRY = None
 
+
 def _check_http_input_type_annotation(bind_name: str, pytype: type) -> bool:
     ext_base = sys.modules.get('azure.functions.extension.base')
     if ext_base is not None and ext_base.HttpV2FeatureChecker.http_v2_enabled():
         return ext_base.RequestTrackerMeta.check_type(pytype)
-        
+
     binding = get_binding(bind_name)
     return binding.check_input_type_annotation(pytype)
 
+
 def _check_http_output_type_annotation(bind_name: str, pytype: type) -> bool:
     ext_base = sys.modules.get('azure.functions.extension.base')
     if ext_base is not None and ext_base.HttpV2FeatureChecker.http_v2_enabled():
         return ext_base.ResponseTrackerMeta.check_type(pytype)
-    
+
     binding = get_binding(bind_name)
     return binding.check_output_type_annotation(pytype)
 
@@ -40,6 +42,7 @@ def _check_http_output_type_annotation(bind_name: str, pytype: type) -> bool:
     HTTP: _check_http_output_type_annotation
 }
 
+
 def load_binding_registry() -> None:
     func = sys.modules.get('azure.functions')
 
@@ -71,15 +74,16 @@ def check_input_type_annotation(bind_name: str, pytype: type) -> bool:
     global INPUT_TYPE_CHECK_OVERRIDE_MAP
     if bind_name in INPUT_TYPE_CHECK_OVERRIDE_MAP:
         return INPUT_TYPE_CHECK_OVERRIDE_MAP[bind_name](bind_name, pytype)
-    
+
     binding = get_binding(bind_name)
     return binding.check_input_type_annotation(pytype)
 
+
 def check_output_type_annotation(bind_name: str, pytype: type) -> bool:
     global OUTPUT_TYPE_CHECK_OVERRIDE_MAP
     if bind_name in OUTPUT_TYPE_CHECK_OVERRIDE_MAP:
         return OUTPUT_TYPE_CHECK_OVERRIDE_MAP[bind_name](bind_name, pytype)
-    
+
     binding = get_binding(bind_name)
     return binding.check_output_type_annotation(pytype)
 

azure_functions_worker/functions.py

@@ -35,6 +35,7 @@ class FunctionInfo(typing.NamedTuple):
 
     trigger_metadata: typing.Optional[typing.Dict[str, typing.Any]]
 
+
 class FunctionLoadError(RuntimeError):
 
     def __init__(self, function_name: str, msg: str) -> None:
@@ -301,7 +302,8 @@ def add_func_to_registry_and_return_funcinfo(self, function,
                                                  return_type: str):
 
         http_trigger_param_name = next(
-            (input_type for input_type, type_info in input_types.items() if type_info.binding_name == HTTP_TRIGGER),
+            (input_type for input_type, type_info in input_types.items()
+             if type_info.binding_name == HTTP_TRIGGER),
             None
         )
 
@@ -323,7 +325,6 @@ def add_func_to_registry_and_return_funcinfo(self, function,
             output_types=output_types,
             return_type=return_type,
             trigger_metadata=trigger_metadata)
-        
 
         self._functions[function_id] = function_info
         return function_info

azure_functions_worker/logging.py

@@ -21,6 +21,7 @@
 handler: Optional[logging.Handler] = None
 error_handler: Optional[logging.Handler] = None
 
+
 def format_exception(exception: Exception) -> str:
     msg = str(exception) + "\n"
     if (sys.version_info.major, sys.version_info.minor) < (3, 10):