Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -194,8 +194,8 @@ async def register_manual(self, caller: 'UtcpClient', manual_call_template: Call
utcp_tool = Tool(
name=mcp_tool.name,
description=mcp_tool.description,
input_schema=mcp_tool.inputSchema,
output_schema=mcp_tool.outputSchema,
inputs=mcp_tool.inputSchema,
outputs=mcp_tool.outputSchema,
tool_call_template=manual_call_template
)
all_tools.append(utcp_tool)
Expand All @@ -212,12 +212,12 @@ async def register_manual(self, caller: 'UtcpClient', manual_call_template: Call
resource_tool = Tool(
name=f"{server_name}.resource_{mcp_resource.name}",
description=f"Read resource: {mcp_resource.description or mcp_resource.name}. URI: {mcp_resource.uri}",
input_schema={
inputs={
"type": "object",
"properties": {},
"required": []
},
output_schema={
outputs={
"type": "object",
"properties": {
"contents": {
Expand Down Expand Up @@ -385,9 +385,9 @@ def _process_tool_result(self, result, tool_name: str) -> Any:
self._log_info(f"Processing tool result for '{tool_name}', type: {type(result)}")

# Check for structured output first
if hasattr(result, 'structured_output'):
self._log_info(f"Found structured_output: {result.structured_output}")
return result.structured_output
if hasattr(result, 'structuredContent'):
self._log_info(f"Found structuredContent: {result.structuredContent}")
return result.structuredContent

# Process content if available
if hasattr(result, 'content'):
Expand Down
Loading