Bugfix: Fix MCP integration by ignoring proxy environment variables

backend/services/remote_mcp_service.py

@@ -1,9 +1,11 @@
 import logging
 import os
 import tempfile
+import httpx
 
 from fastmcp import Client
 from fastmcp.client.transports import StreamableHttpTransport, SSETransport
+from httpx import AsyncClient
 
 from consts.const import CAN_EDIT_ALL_USER_ROLES, PERMISSION_EDIT, PERMISSION_READ
 from consts.exceptions import MCPConnectionError, MCPNameIllegal
@@ -23,6 +25,18 @@
 
 logger = logging.getLogger("remote_mcp_service")
 
+def create_httpx_client(
+    headers: dict[str, str] | None = None,
+    timeout: httpx.Timeout | None = None,
+    auth: httpx.Auth | None = None,
+) -> AsyncClient:
+    return AsyncClient(
+        headers=headers,
+        timeout=timeout,
+        auth=auth,
+        trust_env=False,
+        verify=False, 
+    )
 
 async def mcp_server_health(remote_mcp_server: str, authorization_token: str | None = None) -> bool:
     try:
@@ -33,18 +47,21 @@
         if url_stripped.endswith("/sse"):
             transport = SSETransport(
                 url=url_stripped,
-                headers=headers
+                headers=headers,
+                httpx_client_factory=create_httpx_client
             )
         elif url_stripped.endswith("/mcp"):
             transport = StreamableHttpTransport(
                 url=url_stripped,
-                headers=headers
+                headers=headers,
+                httpx_client_factory=create_httpx_client
             )
         else:
             # Default to StreamableHttpTransport for unrecognized formats
             transport = StreamableHttpTransport(
                 url=url_stripped,
-                headers=headers
+                headers=headers,
+                httpx_client_factory=create_httpx_client
             )
 
         client = Client(transport=transport)

backend/services/tool_configuration_service.py

@@ -37,6 +37,7 @@
 from mcpadapt.smolagents_adapter import _sanitize_function_name
 from services.file_management_service import get_llm_model, validate_urls_access
 from services.vectordatabase_service import get_embedding_model_by_index_name, get_rerank_model
+from services.remote_mcp_service import create_httpx_client
 from database.client import minio_client
 from services.image_service import get_vlm_model
 from nexent.monitor import set_monitoring_context, set_monitoring_operation
@@ -62,12 +63,12 @@ def _create_mcp_transport(url: str, authorization_token: Optional[str] = None):
     headers = {"Authorization": authorization_token} if authorization_token else {}
 
     if url_stripped.endswith("/sse"):
-        return SSETransport(url=url_stripped, headers=headers)
+        return SSETransport(url=url_stripped, headers=headers, httpx_client_factory=create_httpx_client)
     elif url_stripped.endswith("/mcp"):
-        return StreamableHttpTransport(url=url_stripped, headers=headers)
+        return StreamableHttpTransport(url=url_stripped, headers=headers, httpx_client_factory=create_httpx_client)
     else:
         # Default to StreamableHttpTransport for unrecognized formats
-        return StreamableHttpTransport(url=url_stripped, headers=headers)
+        return StreamableHttpTransport(url=url_stripped, headers=headers, httpx_client_factory=create_httpx_client)
 
 
 def python_type_to_json_schema(annotation: Any) -> str:

sdk/pyproject.toml

@@ -51,6 +51,7 @@ dependencies = [
     "pymysql>=1.1.0",
     "psycopg2-binary>=2.9.9",
     "pymssql>=2.2.11",
+    "pandas>=2.2.0",
     "openpyxl>=3.1.5",
     "orjson==3.10",
     "pypdf==6.9.1",