diff --git a/lib/crewai-tools/src/crewai_tools/tools/snowflake_search_tool/snowflake_search_tool.py b/lib/crewai-tools/src/crewai_tools/tools/snowflake_search_tool/snowflake_search_tool.py index fb293319c2..3ce4394a4b 100644 --- a/lib/crewai-tools/src/crewai_tools/tools/snowflake_search_tool/snowflake_search_tool.py +++ b/lib/crewai-tools/src/crewai_tools/tools/snowflake_search_tool/snowflake_search_tool.py @@ -166,7 +166,7 @@ async def _get_connection(self) -> SnowflakeConnection: with self._pool_lock: if self._connection_pool: return self._connection_pool.pop() - return await asyncio.get_event_loop().run_in_executor( + return await asyncio.get_running_loop().run_in_executor( self._thread_pool, self._create_connection ) diff --git a/lib/crewai/src/crewai/tools/structured_tool.py b/lib/crewai/src/crewai/tools/structured_tool.py index 6c24f52dcb..bed4d75eb7 100644 --- a/lib/crewai/src/crewai/tools/structured_tool.py +++ b/lib/crewai/src/crewai/tools/structured_tool.py @@ -261,9 +261,8 @@ async def ainvoke( try: if inspect.iscoroutinefunction(self.func): return await self.func(**parsed_args, **kwargs) - import asyncio - return await asyncio.get_event_loop().run_in_executor( + return await asyncio.get_running_loop().run_in_executor( None, lambda: self.func(**parsed_args, **kwargs) ) except Exception: