Skip to content

Commit a339555

Browse files
added the logs
1 parent a2c77bf commit a339555

File tree

3 files changed

+6
-3
lines changed

3 files changed

+6
-3
lines changed

src/backend/v3/callbacks/response_handlers.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@ def agent_response_callback(message: ChatMessageContent, user_id: str = None) ->
5353
if user_id:
5454
try:
5555
if message.items and message.items[0].content_type == "function_call":
56+
logger.info(f" Message content_type: {message.items[0].content_type}")
5657
logger.info(f"🔧 Tool calls detected from agent: {agent_name}")
5758
final_message = AgentToolMessage(agent_name=agent_name)
5859
for item in message.items:
@@ -74,9 +75,10 @@ def agent_response_callback(message: ChatMessageContent, user_id: str = None) ->
7475
message_type=WebsocketMessageType.AGENT_TOOL_MESSAGE,
7576
)
7677
)
77-
logging.info(f"📤 Tool message sent via WebSocket for user: {user_id}")
78+
logging.info(f"Function call: {final_message}")
7879
elif message.items and message.items[0].content_type == "function_result":
7980
# Log function results for debugging
81+
logger.info(f" Message content_type: {message.items[0].content_type}")
8082
logger.info(f"📥 Function result received from agent: {agent_name}")
8183
for item in message.items:
8284
if item.content_type == "function_result":
@@ -85,6 +87,7 @@ def agent_response_callback(message: ChatMessageContent, user_id: str = None) ->
8587
# skip returning these results for now - agent will return in a later message
8688
pass
8789
else:
90+
logger.info(f" Message content_type: {message.items[0].content_type}")
8891
logger.info(f"💬 Text message from agent: {agent_name}")
8992
final_message = AgentMessage(
9093
agent_name=agent_name,

src/backend/v3/magentic_agents/common/lifecycle.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ async def _after_open(self) -> None:
7777

7878
async def _enter_mcp_if_configured(self) -> None:
7979
if not self.mcp_cfg:
80-
logger.debug("No MCP configuration provided")
80+
logger.error("No MCP configuration provided")
8181
return
8282
# headers = self._build_mcp_headers()
8383
plugin = MCPStreamableHttpPlugin(

src/backend/v3/magentic_agents/proxy_agent.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,7 @@ async def _wait_for_user_clarification(
291291
# Wait for clarification with timeout using the new event-driven method
292292
answer = await orchestration_config.wait_for_clarification(request_id)
293293

294-
logger.info(f"Clarification received for: {request_id}")
294+
logger.info(f"Clarification received for {request_id} : {answer}")
295295
return UserClarificationResponse(
296296
request_id=request_id,
297297
answer=answer,

0 commit comments

Comments
 (0)