Skip to content

Commit f9769ca

Browse files
authored
Merge branch 'dev' into feat/file_parser_debug
2 parents 7ee9f36 + c590f3f commit f9769ca

File tree

4 files changed

+241
-227
lines changed

4 files changed

+241
-227
lines changed

src/memos/mem_scheduler/base_scheduler.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -589,7 +589,9 @@ def submit_messages(self, messages: ScheduleMessageItem | list[ScheduleMessageIt
589589
self.memos_message_queue.submit_messages(messages=messages)
590590

591591
def _submit_web_logs(
592-
self, messages: ScheduleLogForWebItem | list[ScheduleLogForWebItem]
592+
self,
593+
messages: ScheduleLogForWebItem | list[ScheduleLogForWebItem],
594+
additional_log_info: str | None = None,
593595
) -> None:
594596
"""Submit log messages to the web log queue and optionally to RabbitMQ.
595597
@@ -620,7 +622,9 @@ def _submit_web_logs(
620622
if self.is_rabbitmq_connected():
621623
logger.info(f"Submitted Scheduling log to rabbitmq: {message_info}")
622624
self.rabbitmq_publish_message(message=message.to_dict())
623-
logger.debug(f"{len(messages)} submitted. {self._web_log_message_queue.qsize()} in queue.")
625+
logger.debug(
626+
f"{len(messages)} submitted. {self._web_log_message_queue.qsize()} in queue. additional_log_info: {additional_log_info}"
627+
)
624628

625629
def get_web_log_messages(self) -> list[dict]:
626630
"""

0 commit comments

Comments
 (0)