CakeCN/hsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add app context log

Browse Source
This commit is contained in:
CakeCN
2025-12-11 15:10:02 +08:00
parent ae91b62332
commit 99758ce1f8
1 changed files with 23 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
Html/apps/extension_ase/ase_client/client.py
View File

@@ -433,25 +433,26 @@ class HSAEngineClient(ASEngineClient):
super().__init__(server_url, namespace, id) super().__init__(server_url, namespace, id)
self.chatmanager = chatmanager self.chatmanager = chatmanager
def loadmarkdown(self, fmd, fmdp, fsp): def loadmarkdown(self, fmd, fmdp, fsp):
now = time.time() with self.chatmanager.app.app_context():
# 并行发送三个消息，获取事件对象和ack_id now = time.time()
event1, ack_id1 = self.send_text('markdown-in', fmd, self.id, wait_for_ack=True, return_event=True) # 并行发送三个消息，获取事件对象和ack_id
event2, ack_id2 = self.send_text('markdown-prompt-in', fmdp, self.id, wait_for_ack=True, return_event=True) event1, ack_id1 = self.send_text('markdown-in', fmd, self.id, wait_for_ack=True, return_event=True)
event3, ack_id3 = self.send_text('score-prompt-in', fsp, self.id, wait_for_ack=True, return_event=True) event2, ack_id2 = self.send_text('markdown-prompt-in', fmdp, self.id, wait_for_ack=True, return_event=True)
self.chatmanager.app.logger.info(f"Load markdown time cost: {time.time() - now}") event3, ack_id3 = self.send_text('score-prompt-in', fsp, self.id, wait_for_ack=True, return_event=True)
now = time.time() self.chatmanager.app.logger.info(f"Load markdown time cost: {time.time() - now}")
# 等待所有事件完成 now = time.time()
timeout = 5 # 超时时间 # 等待所有事件完成
success1 = event1.wait(timeout=timeout) timeout = 5 # 超时时间
success2 = event2.wait(timeout=timeout) success1 = event1.wait(timeout=timeout)
success3 = event3.wait(timeout=timeout) success2 = event2.wait(timeout=timeout)
self.chatmanager.app.logger.info(f"Wait markdown time cost: {time.time() - now}") success3 = event3.wait(timeout=timeout)
now = time.time() self.chatmanager.app.logger.info(f"Wait markdown time cost: {time.time() - now}")
# 清理ACK事件 now = time.time()
if ack_id1 in self.ack_events: # 清理ACK事件
del self.ack_events[ack_id1] if ack_id1 in self.ack_events:
if ack_id2 in self.ack_events: del self.ack_events[ack_id1]
del self.ack_events[ack_id2] if ack_id2 in self.ack_events:
if ack_id3 in self.ack_events: del self.ack_events[ack_id2]
del self.ack_events[ack_id3] if ack_id3 in self.ack_events:
return success1 and success2 and success3 del self.ack_events[ack_id3]
return success1 and success2 and success3