fix

Signed-off-by: laminar <[email protected]>

Author: tpiperatgod

src/functions_framework/context/function_context.py

@@ -36,8 +36,8 @@ def __init__(self, name="", version="", dapr_triggers=None, http_trigger=None,
     def from_json(json_dct):
         name = json_dct.get('name')
         version = json_dct.get('version')
-        inputs_list = json_dct.get('inputs')
-        outputs_list = json_dct.get('outputs')
+        inputs_map = json_dct.get('inputs')
+        outputs_map = json_dct.get('outputs')
         _dapr_triggers = json_dct.get('triggers', {}).get('dapr', [])
         http_trigger = json_dct.get('triggers', {}).get('http', None)
         states = json_dct.get('states', {})
@@ -47,16 +47,16 @@ def from_json(json_dct):
         port = json_dct.get('port', 0)
 
         inputs = None
-        if inputs_list:
+        if inputs_map:
             inputs = {}
-            for k, v in inputs_list.items():
+            for k, v in inputs_map.items():
                 input = Component.from_json(v)
                 inputs[k] = input
 
         outputs = None
-        if outputs_list:
+        if outputs_map:
             outputs = {}
-            for k, v in outputs_list.items():
+            for k, v in outputs_map.items():
                 output = Component.from_json(v)
                 outputs[k] = output
 

src/functions_framework/triggers/dapr_trigger/dapr.py

@@ -45,17 +45,13 @@ def start(self, context: RuntimeContext, logger=None):
                 def binding_handler(request: BindingRequest):
                     rt_ctx = deepcopy(context)
                     user_ctx = UserContext(runtime_context=rt_ctx, binding_request=request, logger=logger)
-                    logging.basicConfig(level=logging.DEBUG)
-                    logging.info('Received Message : ' + request.text())
                     self.user_function(user_ctx)
 
             if trigger.component_type.startswith("pubsub"):
                 @self.app.subscribe(pubsub_name=trigger.name, topic=trigger.topic)
                 def topic_handler(event: v1.Event):
                     rt_ctx = deepcopy(context)
                     user_ctx = UserContext(runtime_context=rt_ctx, topic_event=event, logger=logger)
-                    logging.basicConfig(level=logging.DEBUG)
-                    logging.info('Received Message : ' + event.data.__str__())
                     self.user_function(user_ctx)
 
         self.app.run(self.port)