andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-05-06 09:42:39 +00:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

linted

Browse Source
This commit is contained in:
lorenzejay
2026-03-09 16:09:28 -07:00
parent fa3b1d5f64
commit 77ab203154
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lib/crewai/src/crewai/tools/mcp_native_tool.py
View File

@@ -5,12 +5,16 @@ for better performance and connection management.
"""
import asyncio
import logging
import threading
from typing import Any
from crewai.tools import BaseTool
logger = logging.getLogger(__name__)
_mcp_loop_lock = threading.Lock()
_mcp_shared_loop: asyncio.AbstractEventLoop | None = None
_mcp_shared_loop_thread: threading.Thread | None = None
@@ -152,7 +156,7 @@ class MCPNativeTool(BaseTool):
try:
await self._mcp_client.disconnect()
except Exception:
pass # best-effort; may already be stale
logger.debug("Failed to disconnect stale MCP client", exc_info=True)
await self._mcp_client.connect()
@@ -169,7 +173,7 @@ class MCPNativeTool(BaseTool):
try:
await self._mcp_client.disconnect()
except Exception:
pass # best-effort cleanup
logger.debug("Failed to disconnect MCP client during retry", exc_info=True)
await self._mcp_client.connect()
result = await self._mcp_client.call_tool(
self.original_tool_name, kwargs
@@ -180,7 +184,7 @@ class MCPNativeTool(BaseTool):
try:
await self._mcp_client.disconnect()
except Exception:
pass # best-effort cleanup
logger.debug("Failed to disconnect MCP client during cleanup", exc_info=True)
# Extract result content
if isinstance(result, str):