chore: debug statements

build.sh

@@ -0,0 +1,19 @@
+#!/bin/bash
+
+# Remove all files in the 'dist' directory
+rm -f dist/*
+
+# Remove all files in the '../ctim/crewAI/dist' directory
+rm -f ../ctim/crewAI/dist/*
+
+# Build the project using Poetry
+poetry build
+
+# Copy all files from the 'dist' directory to '../ctim/crewAI/dist'
+cp -r dist/* ../ctim/crewAI/dist/
+
+cd ../ctim/
+
+make build && make up
+
+cd ../crewAI

src/crewai/agent.py

@@ -84,6 +84,12 @@ class Agent(BaseAgent):
     def __init__(__pydantic_self__, **data):
         config = data.pop("config", {})
         super().__init__(**config, **data)
+        print(
+            f"[CrewAI.Agent.__init__]: Agent: {__pydantic_self__.role} has been init with ToolsHandler: {__pydantic_self__.tools_handler}"
+        )
+        print(
+            f"[CrewAI.Agent.__init__]: Agent: {__pydantic_self__.role} has been init with ToolsHandler: {__pydantic_self__.callbacks}"
+        )
 
     @model_validator(mode="after")
     def set_agent_executor(self) -> "Agent":
@@ -104,6 +110,9 @@ def set_agent_executor(self) -> "Agent":
         if not self.agent_executor:
             if not self.cache_handler:
                 self.cache_handler = CacheHandler()
+            print(
+                f"[CrewAI.Agent.set_agent_executor]: calling set_cache_handler for agent {self}"
+            )
             self.set_cache_handler(self.cache_handler)
         return self
 
@@ -126,6 +135,11 @@ def execute_task(
         if self.tools_handler:
             # type: ignore # Incompatible types in assignment (expression has type "dict[Never, Never]", variable has type "ToolCalling")
             self.tools_handler.last_used_tool = {}
+            print(
+                f"[CrewAI.Agent.execute_task]: task has a tools_handler: {self.tools_handler}"
+            )
+        else:
+            print("[CrewAI.Agent.execute_task]: task DOES NOT HAVE a tools_handler")
 
         task_prompt = task.prompt()
 
@@ -246,6 +260,12 @@ def create_agent_executor(self, tools=None) -> None:
         bind = self.llm.bind(stop=stop_words)
 
         inner_agent = agent_args | execution_prompt | bind | CrewAgentParser(agent=self)
+
+        print(
+            f"[CrewAI.Agent.create_agent_executor]: setting the agent_executor for agent {self}"
+        )
+        callbacks = executor_args.get("callbacks", "No callbacks found")
+        print(f"[CrewAI.Agent.create_agent_executor]: callbacks are: {callbacks}")
         self.agent_executor = CrewAgentExecutor(
             agent=RunnableAgent(runnable=inner_agent), **executor_args
         )

src/crewai/agents/agent_builder/base_agent.py

@@ -208,7 +208,16 @@ def set_cache_handler(self, cache_handler: CacheHandler) -> None:
             cache_handler: An instance of the CacheHandler class.
         """
         if not self.tools_handler:
+            print(
+                "[CrewAI.BaseAgent.set_cache_handler]: Using the default ToolsHandler"
+            )
+            print(
+                f"[CrewAI.BaseAgent.set_cache_handler]: default ToolsHandler is being used by agent: {self}"
+            )
             self.tools_handler = ToolsHandler()
+        print(
+            f"[CrewAI.BaseAgent.set_cache_handler]: ToolsHandler = {self.tools_handler}"
+        )
         if self.cache:
             self.cache_handler = cache_handler
             self.tools_handler.cache = cache_handler

src/crewai/task.py

@@ -200,7 +200,7 @@ def _execute(self, agent, task, context, tools):
         )
         exported_output = self._export_output(result)
 
-        # type: the responses are usually str but need to figuire out a more elegant solution here
+        # the responses are usually str but need to figuire out a more elegant solution here
         self.output = TaskOutput(
             description=self.description,
             exported_output=exported_output,

tests/conftest.py

@@ -1,4 +1,9 @@
 # conftest.py
 from dotenv import load_dotenv
 
+import os
+
+os.environ["OTEL_SDK_DISABLED"] = "true"
+
+
 load_result = load_dotenv(override=True)