preparing to cut new version

src/crewai/__init__.py

@@ -7,10 +7,6 @@ from crewai.routers import Router
 from crewai.task import Task
 
 
-warnings.filterwarnings(
-    "ignore",
-    message="Valid config keys have changed in V2:",
-)
 warnings.filterwarnings(
     "ignore",
     message="Pydantic serializer warnings:",
@@ -18,5 +14,4 @@ warnings.filterwarnings(
     module="pydantic.main",
 )
 
-
 __all__ = ["Agent", "Crew", "Process", "Task", "Pipeline", "Router"]

src/crewai/agents/crew_agent_executor.py

@@ -83,6 +83,8 @@ class CrewAgentExecutor(CrewAgentExecutorMixin):
             user_prompt = self._format_prompt(self.prompt.get("prompt", ""), inputs)
             self.messages.append(self._format_msg(user_prompt))
 
+        self._show_start_logs()
+
         self.ask_for_human_input = bool(inputs.get("ask_for_human_input", False))
         formatted_answer = self._invoke_loop()
 
@@ -162,6 +164,17 @@ class CrewAgentExecutor(CrewAgentExecutorMixin):
         self._show_logs(formatted_answer)
         return formatted_answer
 
+    def _show_start_logs(self):
+        if self.agent.verbose or (
+            hasattr(self, "crew") and getattr(self.crew, "verbose", False)
+        ):
+            self._printer.print(
+                content=f"\033[1m\033[95m# Agent:\033[00m \033[1m\033[92m{self.agent.role}\033[00m"
+            )
+            self._printer.print(
+                content=f"\033[95m## Task:\033[00m \033[92m{self.task.description}\033[00m"
+            )
+
     def _show_logs(self, formatted_answer: Union[AgentAction, AgentFinish]):
         if self.agent.verbose or (
             hasattr(self, "crew") and getattr(self.crew, "verbose", False)
@@ -176,9 +189,10 @@ class CrewAgentExecutor(CrewAgentExecutorMixin):
                 self._printer.print(
                     content=f"\n\n\033[1m\033[95m# Agent:\033[00m \033[1m\033[92m{self.agent.role}\033[00m"
                 )
-                self._printer.print(
-                    content=f"\033[95m## Thought:\033[00m \033[92m{thought}\033[00m"
-                )
+                if thought and thought != "":
+                    self._printer.print(
+                        content=f"\033[95m## Thought:\033[00m \033[92m{thought}\033[00m"
+                    )
                 self._printer.print(
                     content=f"\033[95m## Using tool:\033[00m \033[92m{formatted_answer.tool}\033[00m"
                 )

src/crewai/project/crew_base.py

@@ -89,7 +89,10 @@ def CrewBase(cls):
             callbacks: Dict[str, Callable],
         ) -> None:
             if llm := agent_info.get("llm"):
-                self.agents_config[agent_name]["llm"] = llms[llm]()
+                try:
+                    self.agents_config[agent_name]["llm"] = llms[llm]()
+                except KeyError:
+                    self.agents_config[agent_name]["llm"] = llm
 
             if tools := agent_info.get("tools"):
                 self.agents_config[agent_name]["tools"] = [

src/crewai/telemetry/telemetry.py

@@ -4,15 +4,28 @@ import asyncio
 import json
 import os
 import platform
+import warnings
 from typing import TYPE_CHECKING, Any, Optional
+from contextlib import contextmanager
 
-import pkg_resources
-from opentelemetry import trace
-from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
-from opentelemetry.sdk.resources import SERVICE_NAME, Resource
-from opentelemetry.sdk.trace import TracerProvider
-from opentelemetry.sdk.trace.export import BatchSpanProcessor
-from opentelemetry.trace import Span, Status, StatusCode
+
+@contextmanager
+def suppress_warnings():
+    with warnings.catch_warnings():
+        warnings.filterwarnings("ignore")
+        yield
+
+
+with suppress_warnings():
+    import pkg_resources
+
+
+from opentelemetry import trace  # noqa: E402
+from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter  # noqa: E402
+from opentelemetry.sdk.resources import SERVICE_NAME, Resource  # noqa: E402
+from opentelemetry.sdk.trace import TracerProvider  # noqa: E402
+from opentelemetry.sdk.trace.export import BatchSpanProcessor  # noqa: E402
+from opentelemetry.trace import Span, Status, StatusCode  # noqa: E402
 
 if TYPE_CHECKING:
     from crewai.crew import Crew
@@ -62,8 +75,9 @@ class Telemetry:
     def set_tracer(self):
         if self.ready and not self.trace_set:
             try:
-                trace.set_tracer_provider(self.provider)
-                self.trace_set = True
+                with suppress_warnings():
+                    trace.set_tracer_provider(self.provider)
+                    self.trace_set = True
             except Exception:
                 self.ready = False
                 self.trace_set = False