revert flag set

Author: hallvictoria

azure_functions_worker/bindings/__init__.py

@@ -8,7 +8,7 @@
 from .meta import has_implicit_output
 from .meta import is_trigger_binding, load_binding_registry
 from .meta import from_incoming_proto, to_outgoing_proto, \
-    to_outgoing_param_binding, set_deferred_bindings_flag
+    to_outgoing_param_binding
 from .out import Out
 
 
@@ -19,5 +19,5 @@
     'check_input_type_annotation', 'check_output_type_annotation',
     'has_implicit_output',
     'from_incoming_proto', 'to_outgoing_proto', 'TraceContext', 'RetryContext',
-    'to_outgoing_param_binding', 'set_deferred_bindings_flag'
+    'to_outgoing_param_binding'
 )

azure_functions_worker/bindings/meta.py

@@ -216,11 +216,12 @@ def get_deferred_binding(bind_name: str,
                          pytype: typing.Optional[type] = None) -> object:
     binding = None
 
-    if DEFERRED_BINDINGS_REGISTRY is None:
+    if (DEFERRED_BINDINGS_REGISTRY is not None
+            and DEFERRED_BINDINGS_REGISTRY.check_supported_type(pytype)):
+        # Set flag once
         global DEFERRED_BINDINGS_ENABLED
-        DEFERRED_BINDINGS_ENABLED = False
-    # Checks if pytype is a supported sdk type
-    elif DEFERRED_BINDINGS_REGISTRY.check_supported_type(pytype):
+        if not DEFERRED_BINDINGS_ENABLED:
+            DEFERRED_BINDINGS_ENABLED = True
         # Returns deferred binding converter
         binding = DEFERRED_BINDINGS_REGISTRY.get(bind_name)
 
@@ -255,14 +256,3 @@ def deferred_bindings_decode(binding: typing.Any,
         DEFERRED_BINDINGS_CACHE[(pb.name, pytype, datum.value.content)]\
             = deferred_binding_type
         return deferred_binding_type
-
-
-def set_deferred_bindings_flag(param_anno: type):
-    # If flag hasn't already been set
-    # If DEFERRED_BINDINGS_REGISTRY is not None
-    # If the binding type is a deferred binding type
-    global DEFERRED_BINDINGS_ENABLED
-    if (not DEFERRED_BINDINGS_ENABLED
-            and DEFERRED_BINDINGS_REGISTRY is not None
-            and DEFERRED_BINDINGS_REGISTRY.check_supported_type(param_anno)):
-        DEFERRED_BINDINGS_ENABLED = True

azure_functions_worker/functions.py

@@ -144,9 +144,6 @@ def validate_function_params(params: dict, bound_params: dict,
             param_has_anno = param.name in annotations
             param_anno = annotations.get(param.name)
 
-            # Check the declared type
-            bindings_utils.set_deferred_bindings_flag(param_anno)
-
             if param_has_anno:
                 if typing_inspect.is_generic_type(param_anno):
                     param_anno_origin = typing_inspect.get_origin(param_anno)