|
@@ -124,9 +124,7 @@ class ThreadRunner:
|
|
|
llm = self.__init_llm_backend(run.assistant_id)
|
|
llm = self.__init_llm_backend(run.assistant_id)
|
|
|
loop = True
|
|
loop = True
|
|
|
while loop:
|
|
while loop:
|
|
|
- #print(
|
|
|
|
|
- "looplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooploop"
|
|
|
|
|
- )
|
|
|
|
|
|
|
+ #print("looplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooplooploop" )
|
|
|
run_steps = RunStepService.get_run_step_list(
|
|
run_steps = RunStepService.get_run_step_list(
|
|
|
session=self.session, run_id=self.run_id, thread_id=run.thread_id
|
|
session=self.session, run_id=self.run_id, thread_id=run.thread_id
|
|
|
)
|
|
)
|
|
@@ -303,9 +301,7 @@ class ThreadRunner:
|
|
|
# 为减少线程同步逻辑，依次处理内/外 tool_call 调用
|
|
# 为减少线程同步逻辑，依次处理内/外 tool_call 调用
|
|
|
if internal_tool_calls:
|
|
if internal_tool_calls:
|
|
|
try:
|
|
try:
|
|
|
- #print(
|
|
|
|
|
- "==========================internal_tool_callsinternal_tool_callsinternal_tool_calls"
|
|
|
|
|
- )
|
|
|
|
|
|
|
+ #print("==========================internal_tool_callsinternal_tool_callsinternal_tool_calls")
|
|
|
#print(internal_tool_calls)
|
|
#print(internal_tool_calls)
|
|
|
## 线程执行有问题 可以改成异步, 这里如果是filesearch要确定只执行一次
|
|
## 线程执行有问题 可以改成异步, 这里如果是filesearch要确定只执行一次
|
|
|
tool_calls_with_outputs = run_with_executor(
|
|
tool_calls_with_outputs = run_with_executor(
|
|
@@ -336,9 +332,7 @@ class ThreadRunner:
|
|
|
session=self.session, run_step_id=new_run_step.id, last_error=e
|
|
session=self.session, run_step_id=new_run_step.id, last_error=e
|
|
|
)
|
|
)
|
|
|
raise e
|
|
raise e
|
|
|
- #print(
|
|
|
|
|
- "aaaaaaaaaaaaaaa===============================================================8888888888888888888888888"
|
|
|
|
|
- )
|
|
|
|
|
|
|
+ #print("aaaaaaaaaaaaaaa===============================================================8888888888888888888888888")
|
|
|
#print(external_tool_call_dict)
|
|
#print(external_tool_call_dict)
|
|
|
if external_tool_call_dict:
|
|
if external_tool_call_dict:
|
|
|
# run 设置为 action required，等待业务完成更新并再次拉起
|
|
# run 设置为 action required，等待业务完成更新并再次拉起
|
|
@@ -405,9 +399,7 @@ class ThreadRunner:
|
|
|
relation_type=RelationType.Assistant,
|
|
relation_type=RelationType.Assistant,
|
|
|
relation_id=assistant_id,
|
|
relation_id=assistant_id,
|
|
|
)
|
|
)
|
|
|
- #print(
|
|
|
|
|
- "token_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_id"
|
|
|
|
|
- )
|
|
|
|
|
|
|
+ #print("token_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_idtoken_id")
|
|
|
#print(self.token_id)
|
|
#print(self.token_id)
|
|
|
#print(token_id)
|
|
#print(token_id)
|
|
|
try:
|
|
try:
|
