Skip to content

Commit

Permalink
More async tool fixes (microsoft#1204)
Browse files Browse the repository at this point in the history
* tool_responses fixes

* [] is false
  • Loading branch information
yenif authored Jan 11, 2024
1 parent 622a291 commit e7ccf5b
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions autogen/agentchat/conversable_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -871,7 +871,7 @@ def generate_tool_calls_reply(
"content": func_return.get("content", ""),
}
)
if len(tool_returns) > 0:
if tool_returns:
return True, {
"role": "tool",
"tool_responses": tool_returns,
Expand Down Expand Up @@ -907,14 +907,12 @@ async def a_generate_tool_calls_reply(
func = self._function_map.get(tool_call.get("function", {}).get("name", None), None)
if func and asyncio.coroutines.iscoroutinefunction(func):
async_tool_calls.append(self._a_execute_tool_call(tool_call))
if len(async_tool_calls) > 0:
if async_tool_calls:
tool_returns = await asyncio.gather(*async_tool_calls)
return True, {
"role": "tool",
"tool_responses": tool_returns,
"content": "\n\n".join(
[self._str_for_tool_response(tool_return["content"]) for tool_return in tool_returns]
),
"content": "\n\n".join([self._str_for_tool_response(tool_return) for tool_return in tool_returns]),
}

return False, None
Expand Down Expand Up @@ -1128,7 +1126,10 @@ async def a_check_termination_and_human_reply(
]
)

response = {"role": "user", "content": reply, "tool_responses": tool_returns}
response = {"role": "user", "content": reply}
if tool_returns:
response["tool_responses"] = tool_returns

return True, response

# increment the consecutive_auto_reply_counter
Expand Down

0 comments on commit e7ccf5b

Please sign in to comment.