Update agents/mcp/mcp_client.py

agents/mcp/mcp_client.py

@@ -1,7 +1,6 @@
-import asyncio
+import anyio, asyncio, concurrent.futures
 from mcp.client.sse import sse_client
 from mcp.client.session import ClientSession, DEFAULT_CLIENT_INFO
-import anyio
 
 MCP_SSE_URL_CHESS_EVALUATION = "https://bstraehle-chess.hf.space/gradio_api/mcp/sse"
 MCP_TOOL_CHESS_EVALUATION    = "chess_evaluation"
@@ -54,4 +53,16 @@ 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))
+    #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))