fix: message

docs/concepts/agents.mdx

@@ -33,7 +33,7 @@ Think of an agent as a member of a team, with specific skills and a particular j
 | **Verbose** *(optional)*   | `verbose`  | Setting this to `True` configures the internal logger to provide detailed execution logs, aiding in debugging and monitoring. Default is `False`.                                                                                              |
 | **Allow Delegation** *(optional)* | `allow_delegation`  | Agents can delegate tasks or questions to one another, ensuring that each task is handled by the most suitable agent. Default is `False`.
 | **Step Callback** *(optional)* | `step_callback`  | A function that is called after each step of the agent. This can be used to log the agent's actions or to perform other operations. It will overwrite the crew `step_callback`.                                                               |
-| **Cache** *(optional)*     | `cache`  | Indicates if the agent should use a cache for tool usage. Default is `True`.                                                                                                                                                                  |
+| gbv vbn zzdsxcdsdfc**Cache** *(optional)*     | `cache`  | Indicates if the agent should use a cache for tool usage. Default is `True`.                                                                                                                                                                  |
 | **System Template** *(optional)*     | `system_template`  | Specifies the system format for the agent. Default is `None`.                                                                                                                                                                  |
 | **Prompt Template** *(optional)*     | `prompt_template`  | Specifies the prompt format for the agent. Default is `None`.                                                                                                                                                                  |
 | **Response Template** *(optional)*     | `response_template`  | Specifies the response format for the agent. Default is `None`.                                                                                                                                                                  |

src/crewai/agent.py

@@ -15,18 +15,27 @@ from crewai.utilities.constants import TRAINED_AGENTS_DATA_FILE, TRAINING_DATA_F
 from crewai.utilities.token_counter_callback import TokenCalcHandler
 from crewai.utilities.training_handler import CrewTrainingHandler
 
-agentops = None
-try:
-    import agentops  # type: ignore # Name "agentops" already defined on line 21
-    from agentops import track_agent  # type: ignore
-except ImportError:
 
-    def track_agent():
+def mock_agent_ops_provider():
+    def track_agent(*args, **kwargs):
         def noop(f):
             return f
 
         return noop
 
+    return track_agent
+
+
+agentops = None
+
+if os.environ.get("AGENTOPS_API_KEY"):
+    try:
+        from agentops import track_agent
+    except ImportError:
+        track_agent = mock_agent_ops_provider()
+else:
+    track_agent = mock_agent_ops_provider()
+
 
 @track_agent()
 class Agent(BaseAgent):

src/crewai/agents/agent_builder/utilities/base_agent_tool.py

@@ -81,7 +81,6 @@ class BaseAgentTools(BaseModel, ABC):
         task_with_assigned_agent = Task(  # type: ignore # Incompatible types in assignment (expression has type "Task", variable has type "str")
             description=task,
             agent=agent,
-            expected_output=agent.i18n.slice("manager_request"),
-            i18n=agent.i18n,
+            expected_output="Your best answer to your coworker asking you this, accounting for the context shared.",
         )
         return agent.execute_task(task_with_assigned_agent, context)

src/crewai/agents/crew_agent_executor.py

@@ -151,7 +151,7 @@ class CrewAgentExecutor(CrewAgentExecutorMixin):
                                 )
                                 self.have_forced_answer = True
                         self.messages.append(
-                            self._format_msg(formatted_answer.text, role="assistant")
+                            self._format_msg(formatted_answer.text, role="user")
                         )
 
         except OutputParserException as e:

src/crewai/cli/plus_api.py

@@ -25,9 +25,7 @@ class PlusAPI:
 
     def _make_request(self, method: str, endpoint: str, **kwargs) -> requests.Response:
         url = urljoin(self.base_url, endpoint)
-        session = requests.Session()
-        session.trust_env = False
-        return session.request(method, url, headers=self.headers, **kwargs)
+        return requests.request(method, url, headers=self.headers, **kwargs)
 
     def login_to_tool_repository(self):
         return self._make_request("POST", f"{self.TOOLS_RESOURCE}/login")

src/crewai/cli/templates/crew/main.py

@@ -2,7 +2,7 @@
 import sys
 from {{folder_name}}.crew import {{crew_name}}Crew
 
-# This main file is intended to be a way for you to run your
+# This main file is intended to be a way for your to run your
 # crew locally, so refrain from adding necessary logic into this file.
 # Replace with inputs you want to test with, it will automatically
 # interpolate any tasks and agents information

src/crewai/cli/templates/tool/.gitignore

@@ -1,10 +0,0 @@
-# Python-generated files
-__pycache__/
-*.py[oc]
-build/
-dist/
-wheels/
-*.egg-info
-
-# Virtual environments
-.venv

src/crewai/cli/templates/tool/pyproject.toml

@@ -1,10 +1,14 @@
-[project]
+[tool.poetry]
 name = "{{folder_name}}"
 version = "0.1.0"
 description = "Power up your crews with {{folder_name}}"
+authors = ["Your Name <you@example.com>"]
 readme = "README.md"
-requires-python = ">=3.10,<=3.13"
-dependencies = [
-    "crewai[tools]>=0.70.1"
-]
 
+[tool.poetry.dependencies]
+python = ">=3.10,<=3.13"
+crewai = { extras = ["tools"], version = ">=0.70.1,<1.0.0" }
+
+[build-system]
+requires = ["poetry-core"]
+build-backend = "poetry.core.masonry.api"

src/crewai/cli/tools/main.py

@@ -4,8 +4,6 @@ import platform
 import subprocess
 import tempfile
 from pathlib import Path
-from netrc import netrc
-import stat
 
 import click
 from rich.console import Console
@@ -149,7 +147,7 @@ class ToolCommand(BaseCommand, PlusAPIMixin):
 
         if login_response.status_code != 200:
             console.print(
-                "Authentication failed. Verify access to the tool repository, or try `crewai login`. ",
+                "Failed to authenticate to the tool repository. Make sure you have the access to tools.",
                 style="bold red",
             )
             raise SystemExit
@@ -161,19 +159,23 @@ class ToolCommand(BaseCommand, PlusAPIMixin):
             "Successfully authenticated to the tool repository.", style="bold green"
         )
 
-    def _set_netrc_credentials(self, credentials, netrc_path=None):
-        if not netrc_path:
-            netrc_filename = "_netrc" if platform.system() == "Windows" else ".netrc"
-            netrc_path = Path.home() / netrc_filename
-            netrc_path.touch(mode=stat.S_IRUSR | stat.S_IWUSR, exist_ok=True)
+    def _set_netrc_credentials(self, credentials):
+        # Create .netrc or _netrc file
+        netrc_filename = "_netrc" if platform.system() == "Windows" else ".netrc"
+        netrc_path = Path.home() / netrc_filename
 
-        netrc_instance = netrc(file=netrc_path)
-        netrc_instance.hosts["app.crewai.com"] = (credentials["username"], "", credentials["password"])
+        netrc_content = f"""machine app.crewai.com
+login {credentials['username']}
+password {credentials['password']}
+"""
 
-        with open(netrc_path, 'w') as file:
-            file.write(str(netrc_instance))
+        with open(netrc_path, "a") as netrc_file:
+            netrc_file.write(netrc_content)
 
-        console.print(f"Added credentials to {netrc_path}", style="bold green")
+        # Set appropriate permissions for Unix-like systems
+        if platform.system() != "Windows":
+            os.chmod(netrc_path, 0o600)
+        console.print(f"Added credentials to {netrc_filename}", style="bold green")
 
     def _add_package(self, tool_details):
         tool_handle = tool_details["handle"]

src/crewai/crew.py

@@ -1,5 +1,6 @@
 import asyncio
 import json
+import os
 import uuid
 import warnings
 from concurrent.futures import Future
@@ -47,10 +48,12 @@ from crewai.utilities.planning_handler import CrewPlanner
 from crewai.utilities.task_output_storage_handler import TaskOutputStorageHandler
 from crewai.utilities.training_handler import CrewTrainingHandler
 
-try:
-    import agentops
-except ImportError:
-    agentops = None
+agentops = None
+if os.environ.get("AGENTOPS_API_KEY"):
+    try:
+        import agentops  # type: ignore
+    except ImportError:
+        pass
 
 if TYPE_CHECKING:
     from crewai.pipeline.pipeline import Pipeline

src/crewai/tools/tool_usage.py

@@ -1,22 +1,26 @@
 import ast
 import datetime
+import os
 import time
 from difflib import SequenceMatcher
 from textwrap import dedent
 from typing import Any, List, Union
 
-import crewai.utilities.events as events
 from crewai.agents.tools_handler import ToolsHandler
 from crewai.task import Task
 from crewai.telemetry import Telemetry
 from crewai.tools.tool_calling import InstructorToolCalling, ToolCalling
 from crewai.tools.tool_usage_events import ToolUsageError, ToolUsageFinished
 from crewai.utilities import I18N, Converter, ConverterError, Printer
+import crewai.utilities.events as events
 
-try:
-    import agentops
-except ImportError:
-    agentops = None
+
+agentops = None
+if os.environ.get("AGENTOPS_API_KEY"):
+    try:
+        import agentops  # type: ignore
+    except ImportError:
+        pass
 
 OPENAI_BIGGER_MODELS = ["gpt-4", "gpt-4o", "o1-preview", "o1-mini"]
 

src/crewai/translations/en.json

@@ -20,8 +20,7 @@
     "getting_input": "This is the agent's final answer: {final_answer}\n\n",
     "summarizer_system_message": "You are a helpful assistant that summarizes text.",
     "sumamrize_instruction": "Summarize the following text, make sure to include all the important information: {group}",
-    "summary": "This is a summary of our conversation so far:\n{merged_summary}",
-    "manager_request": "Your best answer to your coworker asking you this, accounting for the context shared."
+    "summary": "This is a summary of our conversation so far:\n{merged_summary}"
   },
   "errors": {
     "force_final_answer_error": "You can't keep going, this was the best you could do.\n {formatted_answer.text}",

src/crewai/utilities/evaluators/task_evaluator.py

@@ -1,3 +1,4 @@
+import os
 from typing import List
 
 from pydantic import BaseModel, Field
@@ -6,16 +7,26 @@ from crewai.utilities import Converter
 from crewai.utilities.pydantic_schema_parser import PydanticSchemaParser
 
 
-agentops = None
-try:
-    from agentops import track_agent
-except ImportError:
-    def track_agent(name):
+def mock_agent_ops_provider():
+    def track_agent(*args, **kwargs):
         def noop(f):
             return f
 
         return noop
 
+    return track_agent
+
+
+agentops = None
+
+if os.environ.get("AGENTOPS_API_KEY"):
+    try:
+        from agentops import track_agent
+    except ImportError:
+        track_agent = mock_agent_ops_provider()
+else:
+    track_agent = mock_agent_ops_provider()
+
 
 class Entity(BaseModel):
     name: str = Field(description="The name of the entity.")

tests/cli/test_plus_api.py

@@ -92,20 +92,16 @@ class TestPlusAPI(unittest.TestCase):
         )
         self.assertEqual(response, mock_response)
 
-    @patch("crewai.cli.plus_api.requests.Session")
-    def test_make_request(self, mock_session):
+    @patch("crewai.cli.plus_api.requests.request")
+    def test_make_request(self, mock_request):
         mock_response = MagicMock()
-
-        mock_session_instance = mock_session.return_value
-        mock_session_instance.request.return_value = mock_response
+        mock_request.return_value = mock_response
 
         response = self.api._make_request("GET", "test_endpoint")
 
-        mock_session.assert_called_once()
-        mock_session_instance.request.assert_called_once_with(
+        mock_request.assert_called_once_with(
             "GET", f"{self.api.base_url}/test_endpoint", headers=self.api.headers
         )
-        mock_session_instance.trust_env = False
         self.assertEqual(response, mock_response)
 
     @patch("crewai.cli.plus_api.PlusAPI._make_request")