|
@@ -219,12 +219,18 @@ class ThreadRunner:
|
|
|
# 为减少线程同步逻辑,依次处理内/外 tool_call 调用
|
|
|
if internal_tool_calls:
|
|
|
try:
|
|
|
+ ## 线程执行有问题 可以改成异步
|
|
|
tool_calls_with_outputs = run_with_executor(
|
|
|
executor=ThreadRunner.tool_executor,
|
|
|
func=internal_tool_call_invoke,
|
|
|
tasks=internal_tool_calls,
|
|
|
timeout=tool_settings.TOOL_WORKER_EXECUTION_TIMEOUT,
|
|
|
)
|
|
|
+ """
|
|
|
+ tool_calls_with_outputs = internal_tool_call_invoke(
|
|
|
+ internal_tool_calls
|
|
|
+ )
|
|
|
+ """
|
|
|
new_run_step = RunStepService.update_step_details(
|
|
|
session=self.session,
|
|
|
run_step_id=new_run_step.id,
|