Method execute

mcp_demo.py:132–168

Execute agent task

(self, context: Dict[str, Any], params: Dict[str, Any])

        )
    
    async def execute(self, context: Dict[str, Any], params: Dict[str, Any]) -> Dict[str, Any]:
        """Execute agent task"""
        query = context.get("query", "")
        
        if not query:
            return {"status": "error", "error": "No query provided"}
        
        logger.info(f"Processing query: {query}")
        
        try:
            tools = await self.get_registered_tools()
            logger.info(f"Available tools: {len(tools)}")


            # Retrieve related tools
            related_tools = get_related_tools(query, tools)
            logger.info(f"Related tools found: {len(related_tools)}")
                
            response = await self._call_model_with_tools(
                system_prompt="",
                prompt=query,
                tools=related_tools,
                temperature=params.get("temperature", 0.7),
                max_iterations=params.get("max_iterations", 10),
                max_tool_calls=params.get("max_tool_calls", 20)
            )
            
            return {
                "status": "success",
                "answer": response["content"],
                "tool_calls": response["tool_calls_made"],
                "iterations": response["iterations"]
            }
        
        except Exception as e:
            logger.error(f"Error during execution: {e}")
            return {"status": "error", "error": str(e)}


async def main():