chore(crewai-tools): drop self-explanatory comments

Author: greysonlalonde

lib/crewai-tools/src/crewai_tools/adapters/crewai_rag_adapter.py

@@ -252,12 +252,10 @@ def add(self, *args: ContentItem, **kwargs: Unpack[AddDocumentParams]) -> None:
                         if filename.startswith("."):
                             continue
 
-                        # Skip binary files based on extension
                         file_ext = os.path.splitext(filename)[1].lower()
                         if file_ext in binary_extensions:
                             continue
 
-                        # Skip __pycache__ directories
                         if "__pycache__" in root:
                             continue
 

lib/crewai-tools/src/crewai_tools/adapters/enterprise_adapter.py

@@ -46,7 +46,6 @@ def __init__(
 
         schema_props, required = self._extract_schema_info(action_schema)
 
-        # Define field definitions for the model
         field_definitions = {}
         for param_name, param_details in schema_props.items():
             param_desc = param_details.get("description", "")
@@ -59,12 +58,10 @@ def __init__(
             except Exception:
                 field_type = str
 
-            # Create field definition based on requirement
             field_definitions[param_name] = self._create_field_definition(
                 field_type, is_required, param_desc
             )
 
-        # Create the model
         if field_definitions:
             try:
                 args_schema = create_model(  # type: ignore[call-overload]

lib/crewai-tools/src/crewai_tools/adapters/rag_adapter.py

@@ -16,7 +16,6 @@ def __init__(
     ):
         super().__init__()
 
-        # Prepare embedding configuration
         embedding_config = {"api_key": embedding_api_key, **embedding_kwargs}
 
         self._adapter = RAG(

lib/crewai-tools/src/crewai_tools/aws/bedrock/agents/invoke_agent_tool.py

@@ -14,7 +14,6 @@
 )
 
 
-# Load environment variables from .env file
 load_dotenv()
 
 
@@ -66,29 +65,24 @@ def __init__(
         self.enable_trace = enable_trace
         self.end_session = end_session
 
-        # Update the description if provided
         if description:
             self.description = description
 
-        # Validate parameters
         self._validate_parameters()
 
     def _validate_parameters(self) -> None:
         """Validate the parameters according to AWS API requirements."""
         try:
-            # Validate agent_id
             if not self.agent_id:
                 raise BedrockValidationError("agent_id cannot be empty")
             if not isinstance(self.agent_id, str):
                 raise BedrockValidationError("agent_id must be a string")
 
-            # Validate agent_alias_id
             if not self.agent_alias_id:
                 raise BedrockValidationError("agent_alias_id cannot be empty")
             if not isinstance(self.agent_alias_id, str):
                 raise BedrockValidationError("agent_alias_id must be a string")
 
-            # Validate session_id if provided
             if self.session_id and not isinstance(self.session_id, str):
                 raise BedrockValidationError("session_id must be a string")
 
@@ -113,7 +107,6 @@ def _run(self, query: str) -> str:
                 ),
             )
 
-            # Format the prompt with current time
             current_utc = datetime.now(timezone.utc)
             prompt = f"""
 The current time is: {current_utc}
@@ -132,12 +125,9 @@ def _run(self, query: str) -> str:
                 endSession=self.end_session,
             )
 
-            # Process the response
             completion = ""
 
-            # Check if response contains a completion field
             if "completion" in response:
-                # Process streaming response format
                 for event in response.get("completion", []):
                     if "chunk" in event and "bytes" in event["chunk"]:
                         chunk_bytes = event["chunk"]["bytes"]
@@ -161,7 +151,6 @@ def _run(self, query: str) -> str:
                     "response_keys": list(response.keys()),
                 }
 
-                # Add more debug info
                 if "chunk" in response:
                     debug_info["chunk_keys"] = list(response["chunk"].keys())
 

lib/crewai-tools/src/crewai_tools/aws/bedrock/browser/browser_toolkit.py

@@ -135,10 +135,8 @@ class NavigateTool(BrowserBaseTool):
     def _run(self, url: str, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the sync tool."""
         try:
-            # Get page for this thread
             page = self.get_sync_page(thread_id)
 
-            # Validate URL scheme
             parsed_url = urlparse(url)
             if parsed_url.scheme not in ("http", "https"):
                 raise ValueError("URL scheme must be 'http' or 'https'")
@@ -153,10 +151,8 @@ def _run(self, url: str, thread_id: str = "default", **kwargs: Any) -> str:
     async def _arun(self, url: str, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the async tool."""
         try:
-            # Get page for this thread
             page = await self.get_async_page(thread_id)
 
-            # Validate URL scheme
             parsed_url = urlparse(url)
             if parsed_url.scheme not in ("http", "https"):
                 raise ValueError("URL scheme must be 'http' or 'https'")
@@ -191,7 +187,6 @@ def _selector_effective(self, selector: str) -> str:
     def _run(self, selector: str, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the sync tool."""
         try:
-            # Get the current page
             page = self.get_sync_page(thread_id)
 
             # Click on the element
@@ -218,7 +213,6 @@ async def _arun(
     ) -> str:
         """Use the async tool."""
         try:
-            # Get the current page
             page = await self.get_async_page(thread_id)
 
             # Click on the element
@@ -251,7 +245,6 @@ class NavigateBackTool(BrowserBaseTool):
     def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the sync tool."""
         try:
-            # Get the current page
             page = self.get_sync_page(thread_id)
 
             # Navigate back
@@ -266,7 +259,6 @@ def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
     async def _arun(self, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the async tool."""
         try:
-            # Get the current page
             page = await self.get_async_page(thread_id)
 
             # Navigate back
@@ -289,7 +281,6 @@ class ExtractTextTool(BrowserBaseTool):
     def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the sync tool."""
         try:
-            # Import BeautifulSoup
             try:
                 from bs4 import BeautifulSoup
             except ImportError:
@@ -298,10 +289,8 @@ def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
                     " Please install it with 'pip install beautifulsoup4'."
                 )
 
-            # Get the current page
             page = self.get_sync_page(thread_id)
 
-            # Extract text
             content = page.content()
             soup = BeautifulSoup(content, "html.parser")
             return soup.get_text(separator="\n").strip()
@@ -311,7 +300,6 @@ def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
     async def _arun(self, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the async tool."""
         try:
-            # Import BeautifulSoup
             try:
                 from bs4 import BeautifulSoup
             except ImportError:
@@ -320,10 +308,8 @@ async def _arun(self, thread_id: str = "default", **kwargs: Any) -> str:
                     " Please install it with 'pip install beautifulsoup4'."
                 )
 
-            # Get the current page
             page = await self.get_async_page(thread_id)
 
-            # Extract text
             content = await page.content()
             soup = BeautifulSoup(content, "html.parser")
             return soup.get_text(separator="\n").strip()
@@ -341,7 +327,6 @@ class ExtractHyperlinksTool(BrowserBaseTool):
     def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the sync tool."""
         try:
-            # Import BeautifulSoup
             try:
                 from bs4 import BeautifulSoup, Tag
             except ImportError:
@@ -350,10 +335,8 @@ def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
                     " Please install it with 'pip install beautifulsoup4'."
                 )
 
-            # Get the current page
             page = self.get_sync_page(thread_id)
 
-            # Extract hyperlinks
             content = page.content()
             soup = BeautifulSoup(content, "html.parser")
             links = []
@@ -374,7 +357,6 @@ def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
     async def _arun(self, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the async tool."""
         try:
-            # Import BeautifulSoup
             try:
                 from bs4 import BeautifulSoup, Tag
             except ImportError:
@@ -383,10 +365,8 @@ async def _arun(self, thread_id: str = "default", **kwargs: Any) -> str:
                     " Please install it with 'pip install beautifulsoup4'."
                 )
 
-            # Get the current page
             page = await self.get_async_page(thread_id)
 
-            # Extract hyperlinks
             content = await page.content()
             soup = BeautifulSoup(content, "html.parser")
             links = []
@@ -415,10 +395,8 @@ class GetElementsTool(BrowserBaseTool):
     def _run(self, selector: str, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the sync tool."""
         try:
-            # Get the current page
             page = self.get_sync_page(thread_id)
 
-            # Get elements
             elements = page.query_selector_all(selector)
             if not elements:
                 return f"No elements found with selector '{selector}'"
@@ -437,10 +415,8 @@ async def _arun(
     ) -> str:
         """Use the async tool."""
         try:
-            # Get the current page
             page = await self.get_async_page(thread_id)
 
-            # Get elements
             elements = await page.query_selector_all(selector)
             if not elements:
                 return f"No elements found with selector '{selector}'"
@@ -465,10 +441,8 @@ class CurrentWebPageTool(BrowserBaseTool):
     def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the sync tool."""
         try:
-            # Get the current page
             page = self.get_sync_page(thread_id)
 
-            # Get information
             url = page.url
             title = page.title()
             return f"URL: {url}\nTitle: {title}"
@@ -478,10 +452,8 @@ def _run(self, thread_id: str = "default", **kwargs: Any) -> str:
     async def _arun(self, thread_id: str = "default", **kwargs: Any) -> str:
         """Use the async tool."""
         try:
-            # Get the current page
             page = await self.get_async_page(thread_id)
 
-            # Get information
             url = page.url
             title = await page.title()
             return f"URL: {url}\nTitle: {title}"