Merge branch 'main' into main

src/crewai/crew.py

@@ -513,6 +513,8 @@ class Crew(BaseModel):
         inputs: Optional[Dict[str, Any]] = None,
     ) -> CrewOutput:
         for before_callback in self.before_kickoff_callbacks:
+            if inputs is None:
+                inputs = {}
             inputs = before_callback(inputs)
 
         """Starts the crew to work on its assigned tasks."""
@@ -674,6 +676,7 @@ class Crew(BaseModel):
         else:
             self.manager_llm = (
                 getattr(self.manager_llm, "model_name", None)
+                or getattr(self.manager_llm, "model", None)
                 or getattr(self.manager_llm, "deployment_name", None)
                 or self.manager_llm
             )

src/crewai/project/crew_base.py

@@ -1,4 +1,5 @@
 import inspect
+import logging
 from pathlib import Path
 from typing import Any, Callable, Dict, TypeVar, cast
 
@@ -7,12 +8,16 @@ from dotenv import load_dotenv
 
 load_dotenv()
 
+logging.basicConfig(level=logging.WARNING)
+
 T = TypeVar("T", bound=type)
 
 """Base decorator for creating crew classes with configuration and function management."""
 
+
 def CrewBase(cls: T) -> T:
     """Wraps a class with crew functionality and configuration management."""
+
     class WrappedClass(cls):  # type: ignore
         is_crew_class: bool = True  # type: ignore
 
@@ -26,16 +31,9 @@ def CrewBase(cls: T) -> T:
 
         def __init__(self, *args, **kwargs):
             super().__init__(*args, **kwargs)
-
-            agents_config_path = self.base_directory / self.original_agents_config_path
-            tasks_config_path = self.base_directory / self.original_tasks_config_path
-
-            self.agents_config = self.load_yaml(agents_config_path)
-            self.tasks_config = self.load_yaml(tasks_config_path)
-
+            self.load_configurations()
             self.map_all_agent_variables()
             self.map_all_task_variables()
-
             # Preserve all decorated functions
             self._original_functions = {
                 name: method
@@ -51,7 +49,6 @@ def CrewBase(cls: T) -> T:
                     ]
                 )
             }
-
             # Store specific function types
             self._original_tasks = self._filter_functions(
                 self._original_functions, "is_task"
@@ -69,6 +66,44 @@ def CrewBase(cls: T) -> T:
                 self._original_functions, "is_kickoff"
             )
 
+        def load_configurations(self):
+            """Load agent and task configurations from YAML files."""
+            if isinstance(self.original_agents_config_path, str):
+                agents_config_path = (
+                    self.base_directory / self.original_agents_config_path
+                )
+                try:
+                    self.agents_config = self.load_yaml(agents_config_path)
+                except FileNotFoundError:
+                    logging.warning(
+                        f"Agent config file not found at {agents_config_path}. "
+                        "Proceeding with empty agent configurations."
+                    )
+                    self.agents_config = {}
+            else:
+                logging.warning(
+                    "No agent configuration path provided. Proceeding with empty agent configurations."
+                )
+                self.agents_config = {}
+
+            if isinstance(self.original_tasks_config_path, str):
+                tasks_config_path = (
+                    self.base_directory / self.original_tasks_config_path
+                )
+                try:
+                    self.tasks_config = self.load_yaml(tasks_config_path)
+                except FileNotFoundError:
+                    logging.warning(
+                        f"Task config file not found at {tasks_config_path}. "
+                        "Proceeding with empty task configurations."
+                    )
+                    self.tasks_config = {}
+            else:
+                logging.warning(
+                    "No task configuration path provided. Proceeding with empty task configurations."
+                )
+                self.tasks_config = {}
+
         @staticmethod
         def load_yaml(config_path: Path):
             try:

src/crewai/translations/en.json

@@ -43,7 +43,7 @@
     "ask_question": "Ask a specific question to one of the following coworkers: {coworkers}\nThe input to this tool should be the coworker, the question you have for them, and ALL necessary context to ask the question properly, they know nothing about the question, so share absolute everything you know, don't reference things but instead explain them.",
     "add_image": {
       "name": "Add image to content",
-      "description": "See image to understand it's content, you can optionally ask a question about the image",
+      "description": "See image to understand its content, you can optionally ask a question about the image",
       "default_action": "Please provide a detailed description of this image, including all visual elements, context, and any notable details you can observe."
     }
   }

src/crewai/utilities/llm_utils.py

@@ -1,11 +1,7 @@
 import os
 from typing import Any, Dict, List, Optional, Union
 
-from packaging import version
-
 from crewai.cli.constants import DEFAULT_LLM_MODEL, ENV_VARS, LITELLM_PARAMS
-from crewai.cli.utils import read_toml
-from crewai.cli.version import get_crewai_version
 from crewai.llm import LLM