Skip to content

Commit 01b0c8e

Browse files
committed
Add inner message
1 parent 124c491 commit 01b0c8e

File tree

1 file changed

+12
-4
lines changed

1 file changed

+12
-4
lines changed

text_2_sql/autogen/src/autogen_text_2_sql/custom_agents/parallel_query_solving_agent.py

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,12 @@
44

55
from autogen_agentchat.agents import BaseChatAgent
66
from autogen_agentchat.base import Response
7-
from autogen_agentchat.messages import AgentMessage, ChatMessage, TextMessage
7+
from autogen_agentchat.messages import (
8+
AgentEvent,
9+
AgentMessage,
10+
ChatMessage,
11+
TextMessage,
12+
)
813
from autogen_core import CancellationToken
914
import json
1015
import logging
@@ -40,6 +45,8 @@ async def on_messages(
4045
async def on_messages_stream(
4146
self, messages: Sequence[ChatMessage], cancellation_token: CancellationToken
4247
) -> AsyncGenerator[AgentMessage | Response, None]:
48+
inner_messages: List[AgentEvent | ChatMessage] = []
49+
4350
last_response = messages[-1].content
4451
parameter_input = messages[0].content
4552
last_response = messages[-1].content
@@ -76,8 +83,9 @@ async def on_messages_stream(
7683
yield Response(
7784
chat_message=TextMessage(
7885
content=json.dumps(inner_solving_results), source=self.name
79-
)
86+
),
87+
inner_messages=inner_messages,
8088
)
8189

82-
async def on_reset(self, cancellation_token: CancellationToken) -> None:
83-
pass
90+
async def on_reset(self, cancellation_token: CancellationToken) -> None:
91+
pass

0 commit comments

Comments
 (0)