Update agents/mcp/mcp_client.py

agents/mcp/mcp_client.py

@@ -1,4 +1,4 @@
-import anyio, asyncio, concurrent.futures
+import anyio, asyncio
 from mcp.client.sse import sse_client
 from mcp.client.session import ClientSession, DEFAULT_CLIENT_INFO
 
@@ -53,16 +53,4 @@ def call_mcp_tool(mcp_url: str, tool_name: str, arguments: dict, timeout: int =
     Raises:
         Exception: If the MCP call fails
     """
-    #return asyncio.run(call_mcp_tool_async(mcp_url, tool_name, arguments, timeout))
-    try:
-        loop = asyncio.get_event_loop()
-
-        if loop.is_running():
-            with concurrent.futures.ThreadPoolExecutor() as executor:
-                future = executor.submit(asyncio.run, call_mcp_tool_async(mcp_url, tool_name, arguments, timeout))
-
-                return future.result()
-        else:
-            return loop.run_until_complete(call_mcp_tool_async(mcp_url, tool_name, arguments, timeout))
-    except RuntimeError:
-        return asyncio.run(call_mcp_tool_async(mcp_url, tool_name, arguments, timeout))
+    return asyncio.run(call_mcp_tool_async(mcp_url, tool_name, arguments, timeout))