[autofix.ci] apply automated fixes (attempt 2/3)

Author: autofix-ci[bot]

src/backend/base/langflow/api/utils/mcp/__init__.py

@@ -3,15 +3,15 @@
 from langflow.api.utils.mcp.config_utils import (
     auto_configure_starter_projects_mcp,
     get_composer_streamable_http_url,
-    get_project_streamable_http_url,
     get_project_sse_url,
+    get_project_streamable_http_url,
     get_url_by_os,
 )
 
 __all__ = [
     "auto_configure_starter_projects_mcp",
     "get_composer_streamable_http_url",
-    "get_project_streamable_http_url",
     "get_project_sse_url",
+    "get_project_streamable_http_url",
     "get_url_by_os",
 ]

src/backend/base/langflow/api/v1/mcp.py

@@ -148,7 +148,7 @@ async def _dispatch_streamable_http(
         await _streamable_http_manager.handle_request(request.scope, request.receive, request._send)  # noqa: SLF001
     except HTTPException:
         raise
-    except Exception as exc:  # noqa: BLE001
+    except Exception as exc:
         await logger.aexception(f"Error handling Streamable HTTP request: {exc!s}")
         raise HTTPException(status_code=500, detail="Internal server error in Streamable HTTP transport") from exc
     finally:

src/backend/base/langflow/api/v1/mcp_projects.py

@@ -311,7 +311,7 @@ async def list_project_tools(
         return await _dispatch_project_streamable_http(project_id, request, auth_user)
 
     metadata = await _build_project_tools_response(project_id, current_user, mcp_enabled=mcp_enabled)
-    return JSONResponse(content=metadata.model_dump(mode='json'))
+    return JSONResponse(content=metadata.model_dump(mode="json"))
 
 
 @router.head("/{project_id}/sse", response_class=HTMLResponse, include_in_schema=False)
@@ -338,9 +338,7 @@ async def _dispatch_project_streamable_http(
     except HTTPException:
         raise
     except Exception as exc:
-        await logger.aexception(
-            f"Error handling Streamable HTTP request for project {project_id}: {exc!s}"
-        )
+        await logger.aexception(f"Error handling Streamable HTTP request for project {project_id}: {exc!s}")
         raise HTTPException(status_code=500, detail="Internal server error in project MCP transport") from exc
     finally:
         current_request_variables_ctx.reset(request_vars_token)

src/backend/tests/unit/api/v1/test_mcp.py

@@ -80,10 +80,7 @@ async def test_mcp_sse_get_endpoint_invalid_auth(client: AsyncClient):
 
 # Test the POST / endpoint (handles incoming MCP messages)
 async def test_mcp_post_endpoint(
-    client: AsyncClient, 
-    logged_in_headers, 
-    mock_streamable_http_manager,
-    mock_ensure_manager_running
+    client: AsyncClient, logged_in_headers, mock_streamable_http_manager, mock_ensure_manager_running
 ):
     """Test POST / endpoint successfully handles MCP messages."""
     test_message = {"type": "test", "content": "message"}

src/backend/tests/unit/api/v1/test_mcp_projects.py

@@ -72,17 +72,17 @@ def mock_streamable_http_manager():
     """Mock StreamableHTTPSessionManager used by ProjectMCPServer."""
     with patch("langflow.api.v1.mcp_projects.StreamableHTTPSessionManager") as mock_class:
         manager_instance = MagicMock()
-        
+
         # Mock the run() method to return an async context manager
         async_cm = AsyncContextManagerMock()
         manager_instance.run = MagicMock(return_value=async_cm)
-        
+
         # Mock handle_request as an async method (this is what gets called, not handle_post_message)
         manager_instance.handle_request = AsyncMock()
-        
+
         # Make the class constructor return our mocked instance
         mock_class.return_value = manager_instance
-        
+
         yield manager_instance
 
 

src/lfx/src/lfx/services/mcp_composer/service.py

@@ -73,7 +73,9 @@ class MCPComposerService(Service):
 
     def __init__(self):
         super().__init__()
-        self.project_composers: dict[str, dict] = {}  # project_id -> {process, host, port, streamable_http_url, auth_config}
+        self.project_composers: dict[
+            str, dict
+        ] = {}  # project_id -> {process, host, port, streamable_http_url, auth_config}
         self._start_locks: dict[
             str, asyncio.Lock
         ] = {}  # Lock to prevent concurrent start operations for the same project
@@ -1045,9 +1047,7 @@ async def _do_start_project_composer(
 
         project_host = auth_config.get("oauth_host") if auth_config else "unknown"
         project_port = auth_config.get("oauth_port") if auth_config else "unknown"
-        await logger.adebug(
-            f"Starting MCP Composer for project {project_id} on {project_host}:{project_port}"
-        )
+        await logger.adebug(f"Starting MCP Composer for project {project_id} on {project_host}:{project_port}")
 
         # Use a per-project lock to prevent race conditions
         if project_id not in self._start_locks: