mirror of https://github.com/Mai-with-u/MaiBot.git
ruff
parent
35b54ea7b7
commit
e25bdb1148
|
|
@ -289,7 +289,7 @@ class DefaultExpressor:
|
|||
try:
|
||||
if not mark_head:
|
||||
mark_head = True
|
||||
first_bot_msg = bot_message # 保存第一个成功发送的消息对象
|
||||
_first_bot_msg = bot_message # 保存第一个成功发送的消息对象
|
||||
typing = False
|
||||
else:
|
||||
typing = True
|
||||
|
|
|
|||
|
|
@ -4,7 +4,7 @@ from typing import List, Dict, Optional, Any, Tuple
|
|||
from src.common.logger_manager import get_logger
|
||||
from src.chat.models.utils_model import LLMRequest
|
||||
from src.config.config import global_config
|
||||
from src.chat.utils.chat_message_builder import get_raw_msg_by_timestamp_random, build_readable_messages, build_anonymous_messages
|
||||
from src.chat.utils.chat_message_builder import get_raw_msg_by_timestamp_random, build_anonymous_messages
|
||||
from src.chat.focus_chat.heartflow_prompt_builder import Prompt, global_prompt_manager
|
||||
import os
|
||||
import json
|
||||
|
|
|
|||
|
|
@ -251,7 +251,7 @@ class StatisticOutputTask(AsyncTask):
|
|||
continue
|
||||
|
||||
|
||||
for idx, (current_period_key, period_start_time) in enumerate(collect_period):
|
||||
for idx, (_current_period_key, period_start_time) in enumerate(collect_period):
|
||||
if record_timestamp >= period_start_time:
|
||||
for period_key_to_update, _ in collect_period[idx:]:
|
||||
stats[period_key_to_update][TOTAL_REQ_CNT] += 1
|
||||
|
|
@ -321,7 +321,7 @@ class StatisticOutputTask(AsyncTask):
|
|||
|
||||
actual_end_timestamp = min(record_end_timestamp, now)
|
||||
|
||||
for idx, (current_period_key, period_start_time) in enumerate(collect_period):
|
||||
for idx, (_current_period_key, period_start_time) in enumerate(collect_period):
|
||||
if record_start_timestamp < now and actual_end_timestamp > period_start_time:
|
||||
overlap_start = max(record_start_timestamp, period_start_time)
|
||||
overlap_end = min(actual_end_timestamp, now)
|
||||
|
|
@ -395,7 +395,7 @@ class StatisticOutputTask(AsyncTask):
|
|||
self.name_mapping[chat_id] = (chat_name, message_time_ts)
|
||||
|
||||
|
||||
for idx, (current_period_key, period_start_time) in enumerate(collect_period):
|
||||
for idx, (_current_period_key, period_start_time) in enumerate(collect_period):
|
||||
if message_datetime >= period_start_time:
|
||||
for period_key_to_update, _ in collect_period[idx:]:
|
||||
stats[period_key_to_update][TOTAL_MSG_CNT] += 1
|
||||
|
|
|
|||
|
|
@ -5,7 +5,6 @@ from typing import List, Optional, Dict, Any, Set
|
|||
from maim_message import UserInfo
|
||||
from src.common.logger_manager import get_logger
|
||||
from src.chat.utils.chat_message_builder import build_readable_messages
|
||||
from src.config.config import global_config
|
||||
|
||||
# 确保导入路径正确
|
||||
from .chat_observer import ChatObserver
|
||||
|
|
|
|||
|
|
@ -10,11 +10,8 @@ from src.chat.utils.utils import get_embedding
|
|||
from src.common.database import db
|
||||
from .pfc_manager import PFCManager
|
||||
from src.chat.message_receive.chat_stream import ChatStream, chat_manager
|
||||
from typing import Optional, Dict, Any
|
||||
from .pfc_manager import PFCManager
|
||||
from src.chat.message_receive.message import MessageRecv
|
||||
from src.chat.message_receive.storage import MessageStorage
|
||||
from datetime import datetime
|
||||
|
||||
|
||||
logger = get_logger("pfc_processor")
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
from src.tools.tool_can_use.base_tool import BaseTool, register_tool
|
||||
from src.tools.tool_can_use.base_tool import BaseTool
|
||||
from src.chat.person_info.person_info import person_info_manager
|
||||
from src.common.logger_manager import get_logger
|
||||
import time
|
||||
|
|
|
|||
Loading…
Reference in New Issue