@@ -1533,10 +1533,9 @@ async def create_tool_from_a2a_agent(
1533
1533
input_schema = {
1534
1534
"type" : "object" ,
1535
1535
"properties" : {
1536
- "parameters" : {"type" : "object" , "description" : "Parameters to pass to the A2A agent" },
1537
- "interaction_type" : {"type" : "string" , "description" : "Type of interaction" , "default" : "query" },
1536
+ "query" : {"type" : "string" , "description" : "User query" , "default" : "Hello from MCP Gateway Admin UI test!" },
1538
1537
},
1539
- "required" : ["parameters " ],
1538
+ "required" : ["query " ],
1540
1539
},
1541
1540
allow_auto = True ,
1542
1541
annotations = {
@@ -1626,11 +1625,11 @@ async def _call_a2a_agent(self, agent: DbA2AAgent, parameters: Dict[str, Any]):
1626
1625
# Patch: Build correct JSON-RPC params structure from flat UI input
1627
1626
params = None
1628
1627
# If UI sends flat fields, convert to nested message structure
1629
- if isinstance (parameters , dict ) and "parameters " in parameters and "interaction_type" in parameters and isinstance (parameters ["interaction_type " ], str ):
1628
+ if isinstance (parameters , dict ) and "query " in parameters and isinstance (parameters ["query " ], str ):
1630
1629
# Build the nested message object
1631
1630
message_id = f"admin-test-{ int (time .time ())} "
1632
- params = {"message" : {"messageId" : message_id , "role" : "user" , "parts" : [{"type" : "text" , "text" : parameters ["interaction_type " ]}]}}
1633
- method = parameters .get ("parameters " , "message/send" )
1631
+ params = {"message" : {"messageId" : message_id , "role" : "user" , "parts" : [{"type" : "text" , "text" : parameters ["query " ]}]}}
1632
+ method = parameters .get ("method " , "message/send" )
1634
1633
else :
1635
1634
# Already in correct format or unknown, pass through
1636
1635
params = parameters .get ("params" , parameters )
0 commit comments