|
@@ -409,16 +409,6 @@ class AgentService:
|
|
|
# 问题在于,如果每次创建出新的PushTaskWorkerPool,在上次任务有未处理完的消息即退出时,会有未处理的消息堆积
|
|
|
push_task_worker_pool.wait_to_finish()
|
|
|
|
|
|
- def _generate_active_greeting_message(self, agent: DialogueManager, user_tags: List[str]=None):
|
|
|
- chat_config = agent.build_active_greeting_config(user_tags)
|
|
|
- chat_response = self._call_chat_api(chat_config, ChatServiceType.OPENAI_COMPATIBLE)
|
|
|
- chat_response = self.sanitize_response(chat_response)
|
|
|
- if response := agent.generate_response(chat_response):
|
|
|
- return response
|
|
|
- else:
|
|
|
- logger.warning(f"staff[{agent.staff_id}] user[{agent.user_id}]: no response generated")
|
|
|
- return None
|
|
|
-
|
|
|
def _get_chat_response(self, user_id: str, agent: DialogueManager,
|
|
|
user_message: Optional[str]):
|
|
|
"""处理LLM响应"""
|