fix(scheduler): Correct misleading logs in reorganize consumer

The  and its helper function
 contained several logging errors
due to being copied from the 'mem_read' consumer without modification.

This commit corrects the following:
- The handler info log now correctly uses the .
- All log messages now refer to 'mem_reorganize' instead of 'mem_read'.
- Exception logs now correctly cite
  and  as the source of the error.

These changes ensure that the logs for the reorganize functionality are
accurate and not misleading, which is critical for monitoring and debugging.
The core business logic of the function, which appears to be missing,
has not been altered.

Author: [email protected]

src/memos/mem_scheduler/general_scheduler.py

@@ -636,7 +636,7 @@ def _process_memories_with_reader(
             )
 
     def _mem_reorganize_message_consumer(self, messages: list[ScheduleMessageItem]) -> None:
-        logger.info(f"Messages {messages} assigned to {MEM_READ_LABEL} handler.")
+        logger.info(f"Messages {messages} assigned to {MEM_ORGANIZE_LABEL} handler.")
 
         def process_message(message: ScheduleMessageItem):
             try:
@@ -652,7 +652,7 @@ def process_message(message: ScheduleMessageItem):
                     return
 
                 logger.info(
-                    f"Processing mem_read for user_id={user_id}, mem_cube_id={mem_cube_id}, mem_ids={mem_ids}"
+                    f"Processing mem_reorganize for user_id={user_id}, mem_cube_id={mem_cube_id}, mem_ids={mem_ids}"
                 )
 
                 # Get the text memory from the mem_cube
@@ -795,11 +795,11 @@ def process_message(message: ScheduleMessageItem):
                         self._submit_web_logs([event])
 
                 logger.info(
-                    f"Successfully processed mem_read for user_id={user_id}, mem_cube_id={mem_cube_id}"
+                    f"Successfully processed mem_reorganize for user_id={user_id}, mem_cube_id={mem_cube_id}"
                 )
 
             except Exception as e:
-                logger.error(f"Error processing mem_read message: {e}", exc_info=True)
+                logger.error(f"Error processing mem_reorganize message: {e}", exc_info=True)
 
         with ContextThreadPoolExecutor(max_workers=min(8, len(messages))) as executor:
             futures = [executor.submit(process_message, msg) for msg in messages]
@@ -858,7 +858,7 @@ def _process_memories_with_reorganize(
 
         except Exception:
             logger.error(
-                f"Error in _process_memories_with_reader: {traceback.format_exc()}", exc_info=True
+                f"Error in _process_memories_with_reorganize: {traceback.format_exc()}", exc_info=True
             )
 
     def _pref_add_message_consumer(self, messages: list[ScheduleMessageItem]) -> None: