fix

Author: tangg555

src/memos/mem_scheduler/task_schedule_modules/local_queue.py

@@ -28,7 +28,6 @@ def __init__(
         maxsize: int = 0,
         stream_key_prefix: str = DEFAULT_STREAM_KEY_PREFIX,
         orchestrator: SchedulerOrchestrator | None = None,
-        max_len: int | None = None,
         status_tracker: TaskStatusTracker | None = None,
     ):
         """
@@ -39,18 +38,13 @@ def __init__(
             maxsize (int): Maximum number of messages allowed in each individual queue.
             stream_key_prefix (str): Prefix for stream keys (simulated).
             orchestrator: SchedulerOrchestrator instance (ignored).
-            max_len: Alias for maxsize if maxsize is 0.
             status_tracker: TaskStatusTracker instance (ignored).
         """
         super().__init__()
 
         self.stream_key_prefix = stream_key_prefix or "local_queue"
 
-        # Use max_len as maxsize if maxsize is not provided
-        if maxsize == 0 and max_len is not None:
-            self.max_internal_message_queue_size = max_len
-        else:
-            self.max_internal_message_queue_size = maxsize
+        self.max_internal_message_queue_size = maxsize
 
         # Dictionary to hold per-stream queues: key = stream_key, value = Queue[ScheduleMessageItem]
         self.queue_streams: dict[str, Queue[ScheduleMessageItem]] = {}