add debug logs to publish output and session utils

Author: paarijaat

FunctionWorker/python/PublicationUtils.py

@@ -391,6 +391,7 @@ def _generate_trigger_metadata(self, topic_next):
     def _publish_output(self, key, trigger, lqcpub, timestamp_map=None):
         if timestamp_map is not None:
             timestamp_map['t_pub_output'] = time.time() * 1000.0
+        self._logger.debug(f"[_publish_output] key: {key}, trigger: {str(trigger)}")
         next = trigger["next"]
 
         if "to_running_function" in trigger and trigger["to_running_function"]:

FunctionWorker/python/SessionUtils.py

@@ -431,6 +431,7 @@ def send_to_running_function_in_session(self, session_function_id, message, send
         #self._logger.debug("[SessionUtils] Sending message to running function: " + str(session_function_id) + " now: " + str(send_now))
         # send the message to the specific running function id
         function_metadatastr = self._global_data_layer_client.getMapEntry(self._map_name_session_functions, session_function_id)
+        self._logger.debug(f"[SessionUtils] Sending message to running function: {str(session_function_id)}, now: {str(send_now)}, function_metadata: {str(function_metadatastr)}")
         try:
             #self._logger.debug("[SessionUtils] function metadata: " + function_metadatastr)
             function_metadata = json.loads(function_metadatastr)