Apply ruff check/format

Author: glin1993@outlook.com

src/memos/mem_scheduler/base_scheduler.py

@@ -863,7 +863,9 @@ def _submit_web_logs(
             logger.debug(f"Submitted Scheduling log for web: {message_info}")
 
             # 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_info}")
+            logger.info(
+                f"[DIAGNOSTIC] base_scheduler._submit_web_logs: enqueue publish {message_info}"
+            )
             self.rabbitmq_publish_message(message=message.to_dict())
         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

@@ -4,8 +4,8 @@
 import threading
 import time
 
-from queue import Empty
 from pathlib import Path
+from queue import Empty
 
 from memos.configs.mem_scheduler import AuthConfig, RabbitMQConfig
 from memos.context.context import ContextThread
@@ -79,7 +79,9 @@ def initialize_rabbitmq(
         """
         with self._rabbitmq_lock:
             if self._rabbitmq_initializing:
-                logger.info("[DIAGNOSTIC] initialize_rabbitmq: initialization already in progress; skipping duplicate call.")
+                logger.info(
+                    "[DIAGNOSTIC] initialize_rabbitmq: initialization already in progress; skipping duplicate call."
+                )
                 return
             self._rabbitmq_initializing = True
         try:
@@ -349,7 +351,7 @@ def rabbitmq_publish_message(self, message: dict):
                 self.initialize_rabbitmq(config=self.rabbitmq_config)
                 return False
 
-            logger.warning(
+            logger.info(
                 f"[DIAGNOSTIC] rabbitmq_service.rabbitmq_publish_message: Attempting to publish message. Exchange: {exchange_name}, Routing Key: {routing_key}, Message Content: {json.dumps(message, indent=2, ensure_ascii=False)}"
             )
             try: