Scheduler: fix bugs in log (#746)

* fix bugs: try to fix bugs in _submit_web_logs

* fix bugs: try to address bugs

Author: tangg555

src/memos/mem_scheduler/base_scheduler.py

@@ -842,12 +842,7 @@ def _submit_web_logs(
             messages = [messages]  # transform single message to list
 
         for message in messages:
-            logger.info(
-                f"[DIAGNOSTIC] base_scheduler._submit_web_logs called. Message to publish: {message.model_dump_json(indent=2)}"
-            )
-
-        try:
-            for message in messages:
+            try:
                 # Always call publish; the publisher now caches when offline and flushes after reconnect
                 logger.info(
                     f"[DIAGNOSTIC] base_scheduler._submit_web_logs: enqueue publish {message.model_dump_json(indent=2)}"
@@ -860,8 +855,10 @@ def _submit_web_logs(
                     message.task_id,
                     message.label,
                 )
-        except Exception as e:
-            logger.error(f"[DIAGNOSTIC] base_scheduler._submit_web_logs failed: {e}", exc_info=True)
+            except Exception as e:
+                logger.error(
+                    f"[DIAGNOSTIC] base_scheduler._submit_web_logs failed: {e}", exc_info=True
+                )
 
         logger.debug(
             f"{len(messages)} submitted. {self._web_log_message_queue.qsize()} in queue. additional_log_info: {additional_log_info}"

src/memos/mem_scheduler/webservice_modules/rabbitmq_service.py

@@ -7,6 +7,8 @@
 from pathlib import Path
 from queue import Empty
 
+from pyglet.libs.win32.constants import FALSE
+
 from memos.configs.mem_scheduler import AuthConfig, RabbitMQConfig
 from memos.context.context import ContextThread
 from memos.dependency import require_python_package
@@ -325,14 +327,14 @@ def rabbitmq_publish_message(self, message: dict):
                 f"[DIAGNOSTIC] Publishing {label} message in Cloud Env. "
                 f"Exchange: {exchange_name}, Routing Key: '{routing_key}'."
             )
-            logger.info(f"  - Message Content: {json.dumps(message, indent=2)}")
+            logger.info(f"  - Message Content: {json.dumps(message, indent=2, ensure_ascii=FALSE)}")
         elif label == "knowledgeBaseUpdate":
             # Original diagnostic logging for knowledgeBaseUpdate if NOT in cloud env
             logger.info(
                 f"[DIAGNOSTIC] Publishing knowledgeBaseUpdate message (Local Env). "
                 f"Current configured Exchange: {exchange_name}, Routing Key: '{routing_key}'."
             )
-            logger.info(f"  - Message Content: {json.dumps(message, indent=2)}")
+            logger.info(f"  - Message Content: {json.dumps(message, indent=2, ensure_ascii=FALSE)}")
 
         with self._rabbitmq_lock:
             logger.info(