Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 0 additions & 6 deletions src/memos/mem_scheduler/schemas/monitor_schemas.py
Original file line number Diff line number Diff line change
Expand Up @@ -141,10 +141,6 @@ def get_queries_with_timesort(self, reverse: bool = True) -> list[str]:
def to_json(self) -> str:
"""Serialize the queue to a JSON string.

Args:
item_serializer: Optional function to serialize individual items.
If not provided, items must be JSON-serializable.

Returns:
A JSON string representing the queue's content and maxsize.
"""
Expand All @@ -160,8 +156,6 @@ def from_json(cls, json_str: str) -> "QueryMonitorQueue":

Args:
json_str: JSON string created by to_json()
item_deserializer: Optional function to reconstruct items from dicts.
If not provided, items are used as-is.

Returns:
A new AutoDroppingQueue instance with deserialized data.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,10 +29,7 @@

class SchedulerOrchestrator(RedisSchedulerModule):
def __init__(self):
"""
Args:
queue: An instance of `SchedulerRedisQueue`.
"""
"""Initialize the orchestrator with an empty fetch cache."""
# Cache of fetched messages grouped by (user_id, mem_cube_id, task_label)
self._cache = None
self.tasks_priorities = {}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,6 @@ def __init__(
consumer_group: Name of the consumer group
consumer_name: Name of the consumer (auto-generated if None)
max_len: Maximum length of the stream (for memory management)
maxsize: Maximum size of the queue (for Queue compatibility, ignored)
auto_delete_acked: Whether to automatically delete acknowledged messages from stream
"""
super().__init__()
Expand Down
Loading