We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 35af8f6 commit 9f71f0aCopy full SHA for 9f71f0a
src/memos/mem_scheduler/schemas/general_schemas.py
@@ -1,3 +1,5 @@
1
+import os
2
+
3
from pathlib import Path
4
5
@@ -21,7 +23,7 @@
21
23
DEFAULT_MAX_INTERNAL_MESSAGE_QUEUE_SIZE = -1
22
24
DEFAULT_TOP_K = 5
25
DEFAULT_CONTEXT_WINDOW_SIZE = 5
-DEFAULT_USE_REDIS_QUEUE = True
26
+DEFAULT_USE_REDIS_QUEUE = os.getenv("MEMSCHEDULER_USE_REDIS_QUEUE", "False").lower() == "true"
27
DEFAULT_MULTI_TASK_RUNNING_TIMEOUT = 30
28
DEFAULT_SCHEDULER_RETRIEVER_BATCH_SIZE = 20
29
DEFAULT_SCHEDULER_RETRIEVER_RETRIES = 1
src/memos/mem_scheduler/task_schedule_modules/redis_queue.py
@@ -785,7 +785,7 @@ def qsize(self) -> dict:
785
Total number of messages across all matching streams.
786
"""
787
if not self._redis_conn:
788
- return 0
+ return {}
789
790
total_size = 0
791
try:
0 commit comments