🤖 自动格式化代码 [skip ci]
This commit is contained in:
@@ -193,7 +193,7 @@ class WorkingMemoryProcessor(BaseProcessor):
|
|||||||
if working_memory is None:
|
if working_memory is None:
|
||||||
logger.warning(f"{self.log_prefix} 工作记忆对象为None,无法压缩聊天记忆")
|
logger.warning(f"{self.log_prefix} 工作记忆对象为None,无法压缩聊天记忆")
|
||||||
return
|
return
|
||||||
|
|
||||||
try:
|
try:
|
||||||
summary_result, _ = await self.llm_model.generate_response_async(obs.compressor_prompt)
|
summary_result, _ = await self.llm_model.generate_response_async(obs.compressor_prompt)
|
||||||
if not summary_result:
|
if not summary_result:
|
||||||
@@ -250,7 +250,7 @@ class WorkingMemoryProcessor(BaseProcessor):
|
|||||||
if working_memory is None:
|
if working_memory is None:
|
||||||
logger.warning(f"{self.log_prefix} 工作记忆对象为None,无法合并记忆")
|
logger.warning(f"{self.log_prefix} 工作记忆对象为None,无法合并记忆")
|
||||||
return
|
return
|
||||||
|
|
||||||
try:
|
try:
|
||||||
merged_memory = await working_memory.merge_memory(memory_id1, memory_id2)
|
merged_memory = await working_memory.merge_memory(memory_id1, memory_id2)
|
||||||
logger.debug(f"{self.log_prefix} 合并后的记忆梗概: {merged_memory.brief}")
|
logger.debug(f"{self.log_prefix} 合并后的记忆梗概: {merged_memory.brief}")
|
||||||
|
|||||||
@@ -44,7 +44,6 @@ if bot_global_config.lpmm_knowledge.enable:
|
|||||||
logger.info(f"KG节点数量:{len(kg_manager.graph.get_node_list())}")
|
logger.info(f"KG节点数量:{len(kg_manager.graph.get_node_list())}")
|
||||||
logger.info(f"KG边数量:{len(kg_manager.graph.get_edge_list())}")
|
logger.info(f"KG边数量:{len(kg_manager.graph.get_edge_list())}")
|
||||||
|
|
||||||
|
|
||||||
# 数据比对:Embedding库与KG的段落hash集合
|
# 数据比对:Embedding库与KG的段落hash集合
|
||||||
for pg_hash in kg_manager.stored_paragraph_hashes:
|
for pg_hash in kg_manager.stored_paragraph_hashes:
|
||||||
key = PG_NAMESPACE + "-" + pg_hash
|
key = PG_NAMESPACE + "-" + pg_hash
|
||||||
|
|||||||
@@ -960,7 +960,7 @@ async def get_prompt_info(message: str, threshold: float):
|
|||||||
if qa_manager is None:
|
if qa_manager is None:
|
||||||
logger.debug("LPMM知识库已禁用,跳过知识获取")
|
logger.debug("LPMM知识库已禁用,跳过知识获取")
|
||||||
return ""
|
return ""
|
||||||
|
|
||||||
found_knowledge_from_lpmm = qa_manager.get_knowledge(message)
|
found_knowledge_from_lpmm = qa_manager.get_knowledge(message)
|
||||||
|
|
||||||
end_time = time.time()
|
end_time = time.time()
|
||||||
|
|||||||
@@ -39,7 +39,7 @@ class KnowledgeFetcher:
|
|||||||
if qa_manager is None:
|
if qa_manager is None:
|
||||||
logger.debug(f"[私聊][{self.private_name}]LPMM知识库已禁用,跳过知识获取")
|
logger.debug(f"[私聊][{self.private_name}]LPMM知识库已禁用,跳过知识获取")
|
||||||
return "未找到匹配的知识"
|
return "未找到匹配的知识"
|
||||||
|
|
||||||
knowledge_info = qa_manager.get_knowledge(query)
|
knowledge_info = qa_manager.get_knowledge(query)
|
||||||
logger.debug(f"[私聊][{self.private_name}]LPMM知识库查询结果: {knowledge_info:150}")
|
logger.debug(f"[私聊][{self.private_name}]LPMM知识库查询结果: {knowledge_info:150}")
|
||||||
return knowledge_info
|
return knowledge_info
|
||||||
|
|||||||
Reference in New Issue
Block a user