added logs (fails until new base)

Author: hallvictoria

azure_functions_worker/dispatcher.py

@@ -678,16 +678,22 @@ def index_functions(self, function_path: str):
                     len(indexed_functions))
 
         if indexed_functions:
-            fx_metadata_results = loader.process_indexed_function(
-                self._functions,
-                indexed_functions)
+            fx_metadata_results, bindings_logs = (
+                loader.process_indexed_function(
+                    self._functions,
+                    indexed_functions))
 
             indexed_function_logs: List[str] = []
             for func in indexed_functions:
+                # break this loop down
+                bindings_info = []
+                for binding in func.get_bindings():
+                    deferred_binding_info = bindings_logs.get(binding.name) if bindings_logs.get(binding.name) else ""
+                    bindings_info.append((binding.type, binding.name,
+                                          deferred_binding_info))
+
                 function_log = "Function Name: {}, Function Binding: {}" \
-                    .format(func.get_function_name(),
-                            [(binding.type, binding.name) for binding in
-                             func.get_bindings()])
+                    .format(func.get_function_name(), bindings_info)
                 indexed_function_logs.append(function_log)
 
             logger.info(

azure_functions_worker/loader.py

@@ -123,15 +123,17 @@ def build_variable_interval_retry(retry, max_retry_count, retry_strategy):
 def process_indexed_function(functions_registry: functions.Registry,
                              indexed_functions):
     fx_metadata_results = []
+    bindings_logs = {}
     for indexed_function in indexed_functions:
         function_info = functions_registry.add_indexed_function(
             function=indexed_function)
 
         binding_protos = build_binding_protos(indexed_function)
         retry_protos = build_retry_protos(indexed_function)
 
-        raw_bindings = get_fx_raw_bindings(indexed_function=indexed_function,
-                                           function_info=function_info)
+        raw_bindings, bindings_logs = get_fx_raw_bindings(
+            indexed_function=indexed_function,
+            function_info=function_info)
 
         function_metadata = protos.RpcFunctionMetadata(
             name=function_info.name,
@@ -149,7 +151,7 @@ def process_indexed_function(functions_registry: functions.Registry,
 
         fx_metadata_results.append(function_metadata)
 
-    return fx_metadata_results
+    return fx_metadata_results, bindings_logs
 
 
 @attach_message_to_exception(
@@ -250,4 +252,4 @@ def get_fx_raw_bindings(indexed_function, function_info):
             indexed_function, function_info.input_types)
 
     else:
-        return indexed_function.get_raw_bindings()
+        return indexed_function.get_raw_bindings(), {}