|
@@ -236,6 +236,8 @@ class ThreadRunner:
|
|
|
if self.stream == False and hasattr(response_stream, "choices"):
|
|
if self.stream == False and hasattr(response_stream, "choices"):
|
|
|
response_stream = [response_stream]
|
|
response_stream = [response_stream]
|
|
|
response_msg = llm_callback_handler.handle_llm_response(response_stream)
|
|
response_msg = llm_callback_handler.handle_llm_response(response_stream)
|
|
|
|
|
+ print("response_msg================================================================response_msg")
|
|
|
|
|
+ print(response_msg)
|
|
|
message_creation_run_step = llm_callback_handler.step
|
|
message_creation_run_step = llm_callback_handler.step
|
|
|
print("444444444444444444444444455555555577777777777777777777777")
|
|
print("444444444444444444444444455555555577777777777777777777777")
|
|
|
logging.info("chat_response_message: %s", response_msg)
|
|
logging.info("chat_response_message: %s", response_msg)
|
|
@@ -293,8 +295,10 @@ class ThreadRunner:
|
|
|
},
|
|
},
|
|
|
completed=not external_tool_call_dict,
|
|
completed=not external_tool_call_dict,
|
|
|
)
|
|
)
|
|
|
|
|
+ print("llm_callback_handler.message================================================================llm_callback_handler.message")
|
|
|
|
|
+ print(llm_callback_handler.message)
|
|
|
self.event_handler.pub_message_delta_tool(
|
|
self.event_handler.pub_message_delta_tool(
|
|
|
- message_id=new_run_step.id,
|
|
|
|
|
|
|
+ message_id=llm_callback_handler.message.id,
|
|
|
index=0,
|
|
index=0,
|
|
|
content=json.dumps(tool_calls_with_outputs)
|
|
content=json.dumps(tool_calls_with_outputs)
|
|
|
)
|
|
)
|