Cutting new version with tool ussage bug fix

Author: joaomdmoura

poetry.lock

@@ -1,7 +1,7 @@
 
 [tool.poetry]
 name = "crewai"
-version = "0.11.0"
+version = "0.11.1"
 description = "Cutting-edge framework for orchestrating role-playing, autonomous AI agents. By fostering collaborative intelligence, CrewAI empowers agents to work together seamlessly, tackling complex tasks."
 authors = ["Joao Moura <joao@crewai.com>"]
 readme = "README.md"
@@ -20,7 +20,7 @@ python = ">=3.10,<4.0"
 pydantic = "^2.4.2"
 langchain = "^0.1.0"
 openai = "^1.7.1"
-langchain-openai = "^0.0.2"
+langchain-openai = "^0.0.5"
 opentelemetry-api = "^1.22.0"
 opentelemetry-sdk = "^1.22.0"
 opentelemetry-exporter-otlp-proto-http = "^1.22.0"

pyproject.toml

@@ -16,13 +16,11 @@ def __init__(self, cache: CacheHandler):
         self.cache = cache
         self.last_used_tool = {}
 
-    def on_tool_start(self, calling: ToolCalling) -> Any:
-        """Run when tool starts running."""
-        self.last_used_tool = calling
-
-    def on_tool_end(self, calling: ToolCalling, output: str) -> Any:
+    def on_tool_use(self, calling: ToolCalling, output: str) -> Any:
         """Run when tool ends running."""
-        if self.last_used_tool.tool_name != CacheTools().name:
+        print(f"Tool {calling.tool_name} has been used.")
+        self.last_used_tool = calling
+        if calling.tool_name != CacheTools().name:
             self.cache.add(
                 tool=calling.tool_name,
                 input=calling.arguments,

src/crewai/agents/tools_handler.py

@@ -61,13 +61,13 @@ def use(self, tool_string: str):
         calling = self._tool_calling(tool_string)
         if isinstance(calling, ToolUsageErrorException):
             error = calling.message
-            self._printer.print(content=f"\n\n{error}\n", color="yellow")
+            self._printer.print(content=f"\n\n{error}\n", color="red")
             return error
         try:
             tool = self._select_tool(calling.tool_name)
         except Exception as e:
             error = getattr(e, "message", str(e))
-            self._printer.print(content=f"\n\n{error}\n", color="yellow")
+            self._printer.print(content=f"\n\n{error}\n", color="red")
             return error
         return self._use(tool_string=tool_string, tool=tool, calling=calling)
 
@@ -94,8 +94,6 @@ def _use(
             except Exception:
                 pass
 
-        self.tools_handler.on_tool_start(calling=calling)
-
         result = self.tools_handler.cache.read(
             tool=calling.tool_name, input=calling.arguments
         )
@@ -107,18 +105,19 @@ def _use(
                 self._run_attempts += 1
                 if self._run_attempts > self._max_parsing_attempts:
                     self._telemetry.tool_usage_error(llm=self.llm)
-                    return ToolUsageErrorException(
+                    error = ToolUsageErrorException(
                         self._i18n.errors("tool_usage_exception").format(error=e)
                     ).message
+                    self._printer.print(content=f"\n\n{error}\n", color="red")
+                    return error
                 return self.use(tool_string=tool_string)
 
-            self.tools_handler.on_tool_end(calling=calling, output=result)
+            self.tools_handler.on_tool_use(calling=calling, output=result)
 
         self._printer.print(content=f"\n\n{result}\n", color="yellow")
         self._telemetry.tool_usage(
             llm=self.llm, tool_name=tool.name, attempts=self._run_attempts
         )
-
         result = self._format_result(result=result)
         return result
 

src/crewai/tools/tool_usage.py

@@ -2,8 +2,13 @@ class Printer:
     def print(self, content: str, color: str):
         if color == "yellow":
             self._print_yellow(content)
+        elif color == "red":
+            self._print_red(content)
         else:
             print(content)
 
     def _print_yellow(self, content):
         print("\033[93m {}\033[00m".format(content))
+
+    def _print_red(self, content):
+        print("\033[91m {}\033[00m".format(content))

src/crewai/utilities/printer.py

@@ -125,6 +125,8 @@ def multiplier(first_number: int, second_number: int) -> float:
 
     assert agent.tools_handler.last_used_tool == {}
     task = Task(description="What is 3 times 4?", agent=agent)
+    # force cleaning cache
+    agent.tools_handler.cache = CacheHandler()
     output = agent.execute_task(task)
     tool_usage = InstructorToolCalling(
         tool_name=multiplier.name, arguments={"first_number": 3, "second_number": 4}
@@ -255,6 +257,8 @@ def get_final_answer(numbers) -> float:
     task = Task(
         description="The final answer is 42. But don't give it yet, instead keep using the `get_final_answer` tool."
     )
+    # force cleaning cache
+    agent.tools_handler.cache = CacheHandler()
     agent.execute_task(
         task=task,
         tools=[get_final_answer],