fix: Resolve Ruff linting and formatting issues

Author: glin1993@outlook.com

src/memos/mem_scheduler/base_scheduler.py

@@ -773,7 +773,7 @@ def _message_consumer(self) -> None:
                     for msg in messages:
                         enqueue_ts_obj = getattr(msg, "timestamp", None)
                         enqueue_epoch = None
-                        if isinstance(enqueue_ts_obj, (int, float)):
+                        if isinstance(enqueue_ts_obj, int | float):
                             enqueue_epoch = float(enqueue_ts_obj)
                         elif hasattr(enqueue_ts_obj, "timestamp"):
                             dt = enqueue_ts_obj
@@ -785,13 +785,15 @@ def _message_consumer(self) -> None:
                         if enqueue_epoch is not None:
                             queue_wait_ms = max(0.0, now - enqueue_epoch) * 1000
 
-                        setattr(msg, "dequeue_ts", now)
+                        msg.dequeue_ts = now
                         emit_monitor_event(
                             "dequeue",
                             msg,
                             {
                                 "enqueue_ts": to_iso(enqueue_ts_obj),
-                                "dequeue_ts": datetime.fromtimestamp(now, tz=timezone.utc).isoformat(),
+                                "dequeue_ts": datetime.fromtimestamp(
+                                    now, tz=timezone.utc
+                                ).isoformat(),
                                 "queue_wait_ms": queue_wait_ms,
                             },
                         )

src/memos/mem_scheduler/task_schedule_modules/dispatcher.py

@@ -4,7 +4,7 @@
 
 from collections import defaultdict
 from collections.abc import Callable
-from datetime import timezone
+from datetime import datetime, timezone
 from typing import Any
 
 from memos.context.context import (
@@ -168,7 +168,7 @@ def wrapped_handler(messages: list[ScheduleMessageItem]):
 
                 dequeue_ts = getattr(first_msg, "dequeue_ts", None)
                 start_delay_ms = None
-                if isinstance(dequeue_ts, (int, float)):
+                if isinstance(dequeue_ts, int | float):
                     start_delay_ms = max(0.0, start_time - dequeue_ts) * 1000
 
                 emit_monitor_event(
@@ -180,7 +180,7 @@ def wrapped_handler(messages: list[ScheduleMessageItem]):
                         "enqueue_ts": to_iso(enq_ts),
                         "dequeue_ts": to_iso(
                             datetime.fromtimestamp(dequeue_ts, tz=timezone.utc)
-                            if isinstance(dequeue_ts, (int, float))
+                            if isinstance(dequeue_ts, int | float)
                             else None
                         ),
                     },
@@ -205,7 +205,9 @@ def wrapped_handler(messages: list[ScheduleMessageItem]):
                     {
                         "status": "ok",
                         "start_ts": start_iso,
-                        "finish_ts": datetime.fromtimestamp(finish_time, tz=timezone.utc).isoformat(),
+                        "finish_ts": datetime.fromtimestamp(
+                            finish_time, tz=timezone.utc
+                        ).isoformat(),
                         "exec_duration_ms": duration * 1000,
                     },
                 )
@@ -233,7 +235,9 @@ def wrapped_handler(messages: list[ScheduleMessageItem]):
                     {
                         "status": "fail",
                         "start_ts": start_iso,
-                        "finish_ts": datetime.fromtimestamp(finish_time, tz=timezone.utc).isoformat(),
+                        "finish_ts": datetime.fromtimestamp(
+                            finish_time, tz=timezone.utc
+                        ).isoformat(),
                         "exec_duration_ms": (finish_time - start_time) * 1000,
                         "error_type": type(e).__name__,
                         "error_msg": str(e),

src/memos/mem_scheduler/task_schedule_modules/task_queue.py

@@ -5,14 +5,14 @@
 the local memos_message_queue functionality in BaseScheduler.
 """
 
+from memos.context.context import get_current_trace_id
 from memos.log import get_logger
 from memos.mem_scheduler.schemas.message_schemas import ScheduleMessageItem
-from memos.context.context import get_current_trace_id
 from memos.mem_scheduler.task_schedule_modules.local_queue import SchedulerLocalQueue
 from memos.mem_scheduler.task_schedule_modules.redis_queue import SchedulerRedisQueue
 from memos.mem_scheduler.utils.db_utils import get_utc_now
-from memos.mem_scheduler.utils.monitor_event_utils import emit_monitor_event, to_iso
 from memos.mem_scheduler.utils.misc_utils import group_messages_by_user_and_mem_cube
+from memos.mem_scheduler.utils.monitor_event_utils import emit_monitor_event, to_iso
 
 
 logger = get_logger(__name__)

src/memos/mem_scheduler/utils/monitor_event_utils.py

@@ -1,6 +1,7 @@
 import json
 import os
 import socket
+
 from datetime import datetime, timezone
 from typing import Any