chore: bump version to 0.119.0 and update dependencies (#2778)

This commit updates the project version to 0.119.0 and modifies the required version of the `crewai-tools` dependency to 0.44.0 across various configuration files. Additionally, the version number is reflected in the `__init__.py` file and the CLI templates for crew, flow, and tool projects.

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "crewai"
-version = "0.118.0"
+version = "0.119.0"
 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."
 readme = "README.md"
 requires-python = ">=3.10,<3.13"
@@ -45,7 +45,7 @@ Documentation = "https://docs.crewai.com"
 Repository = "https://github.com/crewAIInc/crewAI"
 
 [project.optional-dependencies]
-tools = ["crewai-tools~=0.42.2"]
+tools = ["crewai-tools~=0.44.0"]
 embeddings = [
     "tiktoken~=0.7.0"
 ]

src/crewai/__init__.py

@@ -17,7 +17,7 @@ warnings.filterwarnings(
     category=UserWarning,
     module="pydantic.main",
 )
-__version__ = "0.118.0"
+__version__ = "0.119.0"
 __all__ = [
     "Agent",
     "Crew",

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

@@ -5,7 +5,7 @@ description = "{{name}} using crewAI"
 authors = [{ name = "Your Name", email = "you@example.com" }]
 requires-python = ">=3.10,<3.13"
 dependencies = [
-    "crewai[tools]>=0.118.0,<1.0.0"
+    "crewai[tools]>=0.119.0,<1.0.0"
 ]
 
 [project.scripts]

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

@@ -5,7 +5,7 @@ description = "{{name}} using crewAI"
 authors = [{ name = "Your Name", email = "you@example.com" }]
 requires-python = ">=3.10,<3.13"
 dependencies = [
-    "crewai[tools]>=0.118.0,<1.0.0",
+    "crewai[tools]>=0.119.0,<1.0.0",
 ]
 
 [project.scripts]

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

@@ -5,7 +5,7 @@ description = "Power up your crews with {{folder_name}}"
 readme = "README.md"
 requires-python = ">=3.10,<3.13"
 dependencies = [
-    "crewai[tools]>=0.118.0"
+    "crewai[tools]>=0.119.0"
 ]
 
 [tool.crewai]

src/crewai/memory/storage/mem0_storage.py

@@ -9,29 +9,8 @@ from crewai.memory.storage.interface import Storage
 class Mem0Storage(Storage):
     """
     Extends Storage to handle embedding and searching across entities using Mem0.
-    
-    Supports Mem0 v2 API with run_id for associating memories with specific conversation
-    sessions. By default, uses v2 API which is recommended for better context management.
-    
-    Args:
-        type: The type of memory storage ("user", "short_term", "long_term", "entities", "external")
-        crew: The crew instance this storage is associated with
-        config: Optional configuration dictionary that overrides crew.memory_config
-        
-    Configuration options:
-        version: API version to use ("v1.1" or "v2", defaults to "v2")
-        run_id: Optional session identifier for associating memories with specific conversations
-        api_key: Mem0 API key (defaults to MEM0_API_KEY environment variable)
-        user_id: User identifier (required for "user" memory type)
-        org_id: Optional organization ID for Mem0 API
-        project_id: Optional project ID for Mem0 API
-        local_mem0_config: Optional configuration for local Mem0 instance
     """
 
-    SUPPORTED_VERSIONS = ["v1.1", "v2"]
-    
-    DEFAULT_VERSION = "v2"
-
     def __init__(self, type, crew=None, config=None):
         super().__init__()
         supported_types = ["user", "short_term", "long_term", "entities", "external"]
@@ -46,12 +25,6 @@ class Mem0Storage(Storage):
         self.config = config or {}
         # TODO: Memory config will be removed in the future the config will be passed as a parameter
         self.memory_config = self.config or getattr(crew, "memory_config", {}) or {}
-        
-        config = self._get_config()
-        self.version = config.get("version", self.DEFAULT_VERSION)
-        self.run_id = config.get("run_id")
-        
-        self._validate_config()
 
         # User ID is required for user memory type "user" since it's used as a unique identifier for the user.
         user_id = self._get_user_id()
@@ -79,70 +52,16 @@ class Mem0Storage(Storage):
             else:
                 self.memory = Memory()
 
-    def _validate_config(self) -> None:
-        """
-        Validate configuration parameters.
-        
-        Raises:
-            ValueError: If the version is not supported
-        """
-        if self.version not in self.SUPPORTED_VERSIONS:
-            raise ValueError(
-                f"Unsupported version: {self.version}. "
-                f"Please use one of: {', '.join(self.SUPPORTED_VERSIONS)}"
-            )
-        
-        if self.run_id is not None and not isinstance(self.run_id, str):
-            raise ValueError("run_id must be a string")
-
-    def _build_params(self, base_params: Dict[str, Any], method: str = "add") -> Dict[str, Any]:
-        """
-        Centralize parameter building for API calls.
-        
-        Args:
-            base_params: Base parameters to build upon
-            method: The method being called ("add" or "search")
-            
-        Returns:
-            Dict[str, Any]: Complete parameters for API call
-        """
-        params = base_params.copy()
-        
-        # Add version and run_id for MemoryClient
-        if isinstance(self.memory, MemoryClient):
-            params["version"] = self.version
-            
-            if self.run_id:
-                params["run_id"] = self.run_id
-        elif isinstance(self.memory, Memory) and method == "search" and "metadata" in params:
-            del params["metadata"]
-            
-        return params
-
     def _sanitize_role(self, role: str) -> str:
         """
         Sanitizes agent roles to ensure valid directory names.
-        
-        Args:
-            role: The role name to sanitize
-            
-        Returns:
-            str: Sanitized role name
         """
         return role.replace("\n", "").replace(" ", "_").replace("/", "_")
 
     def save(self, value: Any, metadata: Dict[str, Any]) -> None:
-        """
-        Save a memory item.
-        
-        Args:
-            value: The memory content to save
-            metadata: Additional metadata for the memory
-        """
         user_id = self._get_user_id()
         agent_name = self._get_agent_name()
         params = None
-        
         if self.memory_type == "short_term":
             params = {
                 "agent_id": agent_name,
@@ -169,7 +88,8 @@ class Mem0Storage(Storage):
             }
 
         if params:
-            params = self._build_params(params, method="add")
+            if isinstance(self.memory, MemoryClient):
+                params["output_format"] = "v1.1"
             self.memory.add(value, **params)
 
     def search(
@@ -178,61 +98,36 @@ class Mem0Storage(Storage):
         limit: int = 3,
         score_threshold: float = 0.35,
     ) -> List[Any]:
-        """
-        Search for memories.
-        
-        Args:
-            query: The search query
-            limit: Maximum number of results to return
-            score_threshold: Minimum score for results to be included
-            
-        Returns:
-            List[Any]: List of memory items that match the query
-        """
-        base_params = {"query": query, "limit": limit}
+        params = {"query": query, "limit": limit, "output_format": "v1.1"}
         if user_id := self._get_user_id():
-            base_params["user_id"] = user_id
+            params["user_id"] = user_id
 
         agent_name = self._get_agent_name()
         if self.memory_type == "short_term":
-            base_params["agent_id"] = agent_name
-            base_params["metadata"] = {"type": "short_term"}
+            params["agent_id"] = agent_name
+            params["metadata"] = {"type": "short_term"}
         elif self.memory_type == "long_term":
-            base_params["agent_id"] = agent_name
-            base_params["metadata"] = {"type": "long_term"}
+            params["agent_id"] = agent_name
+            params["metadata"] = {"type": "long_term"}
         elif self.memory_type == "entities":
-            base_params["agent_id"] = agent_name
-            base_params["metadata"] = {"type": "entity"}
+            params["agent_id"] = agent_name
+            params["metadata"] = {"type": "entity"}
         elif self.memory_type == "external":
-            base_params["agent_id"] = agent_name
-            base_params["metadata"] = {"type": "external"}
+            params["agent_id"] = agent_name
+            params["metadata"] = {"type": "external"}
 
-        params = self._build_params(base_params, method="search")
+        # Discard the filters for now since we create the filters
+        # automatically when the crew is created.
+        if isinstance(self.memory, Memory):
+            del params["metadata"], params["output_format"]
+            
         results = self.memory.search(**params)
-        
-        if isinstance(results, dict) and "results" in results:
-            return [r for r in results["results"] if r["score"] >= score_threshold]
-        elif isinstance(results, list):
-            return [r for r in results if r["score"] >= score_threshold]
-        else:
-            return []
+        return [r for r in results["results"] if r["score"] >= score_threshold]
 
     def _get_user_id(self) -> str:
-        """
-        Get the user ID from configuration.
-        
-        Returns:
-            str: User ID or empty string if not found
-        """
         return self._get_config().get("user_id", "")
 
     def _get_agent_name(self) -> str:
-        """
-        Get the agent name from the crew.
-        
-        Returns:
-            str: Agent name or empty string if not found
-        """
         if not self.crew:
             return ""
 
@@ -242,17 +137,8 @@ class Mem0Storage(Storage):
         return agents
 
     def _get_config(self) -> Dict[str, Any]:
-        """
-        Get the configuration from either config or memory_config.
-        
-        Returns:
-            Dict[str, Any]: Configuration dictionary
-        """
         return self.config or getattr(self, "memory_config", {}).get("config", {}) or {}
 
-    def reset(self) -> None:
-        """
-        Reset the memory.
-        """
+    def reset(self):
         if self.memory:
             self.memory.reset()

tests/storage/test_mem0_storage.py

@@ -195,7 +195,7 @@ def test_save_method_with_memory_client(mem0_storage_with_memory_client_using_co
         agent_id="Test_Agent",
         infer=False,
         metadata={"type": "short_term", "key": "value"},
-        version="v2"
+        output_format="v1.1"
     )
 
 
@@ -232,7 +232,7 @@ def test_search_method_with_memory_client(mem0_storage_with_memory_client_using_
         agent_id="Test_Agent", 
         metadata={"type": "short_term"},
         user_id="test_user",
-        version='v2'
+        output_format='v1.1'
     )
 
     assert len(results) == 1

tests/storage/test_mem0_storage_v2.py

@@ -1,290 +0,0 @@
-import os
-from unittest.mock import MagicMock, patch
-
-import pytest
-from mem0.client.main import MemoryClient
-from mem0.memory.main import Memory
-
-from crewai.agent import Agent
-from crewai.crew import Crew
-from crewai.memory.storage.mem0_storage import Mem0Storage
-from crewai.task import Task
-
-
-class MockCrew:
-    def __init__(self, memory_config):
-        self.memory_config = memory_config
-        self.agents = [MagicMock(role="Test Agent")]
-
-
-@pytest.fixture
-def mock_mem0_memory_client():
-    """Fixture to create a mock MemoryClient instance"""
-    mock_memory = MagicMock(spec=MemoryClient)
-    return mock_memory
-
-
-@pytest.fixture
-def mem0_storage_with_v2_api(mock_mem0_memory_client):
-    """Fixture to create a Mem0Storage instance with v2 API configuration"""
-    
-    with patch.object(MemoryClient, "__new__", return_value=mock_mem0_memory_client):
-        crew = MockCrew(
-            memory_config={
-                "provider": "mem0",
-                "config": {
-                    "user_id": "test_user",
-                    "api_key": "ABCDEFGH",
-                    "version": "v2",  # Explicitly set to v2
-                },
-            }
-        )
-        
-        mem0_storage = Mem0Storage(type="short_term", crew=crew)
-        return mem0_storage, mock_mem0_memory_client
-
-
-@pytest.fixture
-def mem0_storage_with_run_id(mock_mem0_memory_client):
-    """Fixture to create a Mem0Storage instance with run_id configuration"""
-    
-    with patch.object(MemoryClient, "__new__", return_value=mock_mem0_memory_client):
-        crew = MockCrew(
-            memory_config={
-                "provider": "mem0",
-                "config": {
-                    "user_id": "test_user",
-                    "api_key": "ABCDEFGH",
-                    "version": "v2",
-                    "run_id": "test-session-123",  # Set run_id
-                },
-            }
-        )
-        
-        mem0_storage = Mem0Storage(type="short_term", crew=crew)
-        return mem0_storage, mock_mem0_memory_client
-
-
-@pytest.fixture
-def mem0_storage_with_v1_api(mock_mem0_memory_client):
-    """Fixture to create a Mem0Storage instance with v1.1 API configuration"""
-    
-    with patch.object(MemoryClient, "__new__", return_value=mock_mem0_memory_client):
-        crew = MockCrew(
-            memory_config={
-                "provider": "mem0",
-                "config": {
-                    "user_id": "test_user",
-                    "api_key": "ABCDEFGH",
-                    "version": "v1.1",  # Explicitly set to v1.1
-                },
-            }
-        )
-        
-        mem0_storage = Mem0Storage(type="short_term", crew=crew)
-        return mem0_storage, mock_mem0_memory_client
-
-
-@pytest.mark.v2_api
-def test_mem0_storage_v2_initialization(mem0_storage_with_v2_api):
-    """Test that Mem0Storage initializes correctly with v2 API configuration"""
-    mem0_storage, _ = mem0_storage_with_v2_api
-    
-    assert mem0_storage.version == "v2"
-    assert mem0_storage.run_id is None
-
-
-@pytest.mark.v2_api
-def test_mem0_storage_with_run_id_initialization(mem0_storage_with_run_id):
-    """Test that Mem0Storage initializes correctly with run_id configuration"""
-    mem0_storage, _ = mem0_storage_with_run_id
-    
-    assert mem0_storage.version == "v2"
-    assert mem0_storage.run_id == "test-session-123"
-
-
-@pytest.mark.v1_api
-def test_mem0_storage_v1_initialization(mem0_storage_with_v1_api):
-    """Test that Mem0Storage initializes correctly with v1.1 API configuration"""
-    mem0_storage, _ = mem0_storage_with_v1_api
-    
-    assert mem0_storage.version == "v1.1"
-    assert mem0_storage.run_id is None
-
-
-@pytest.mark.v2_api
-def test_save_method_with_v2_api(mem0_storage_with_v2_api):
-    """Test save method with v2 API"""
-    mem0_storage, mock_memory_client = mem0_storage_with_v2_api
-    mock_memory_client.add = MagicMock()
-    
-    test_value = "This is a test memory"
-    test_metadata = {"key": "value"}
-    
-    mem0_storage.save(test_value, test_metadata)
-    
-    mock_memory_client.add.assert_called_once()
-    call_args = mock_memory_client.add.call_args[1]
-    
-    assert call_args["version"] == "v2"
-    assert "run_id" not in call_args
-    assert call_args["agent_id"] == "Test_Agent"
-    assert call_args["metadata"] == {"type": "short_term", "key": "value"}
-
-
-@pytest.mark.v2_api
-def test_save_method_with_run_id(mem0_storage_with_run_id):
-    """Test save method with run_id"""
-    mem0_storage, mock_memory_client = mem0_storage_with_run_id
-    mock_memory_client.add = MagicMock()
-    
-    test_value = "This is a test memory"
-    test_metadata = {"key": "value"}
-    
-    mem0_storage.save(test_value, test_metadata)
-    
-    mock_memory_client.add.assert_called_once()
-    call_args = mock_memory_client.add.call_args[1]
-    
-    assert call_args["version"] == "v2"
-    assert call_args["run_id"] == "test-session-123"
-    assert call_args["agent_id"] == "Test_Agent"
-    assert call_args["metadata"] == {"type": "short_term", "key": "value"}
-
-
-@pytest.mark.v2_api
-def test_search_method_with_v2_api(mem0_storage_with_v2_api):
-    """Test search method with v2 API"""
-    mem0_storage, mock_memory_client = mem0_storage_with_v2_api
-    mock_results = {"results": [{"score": 0.9, "content": "Result 1"}, {"score": 0.4, "content": "Result 2"}]}
-    mock_memory_client.search = MagicMock(return_value=mock_results)
-    
-    results = mem0_storage.search("test query", limit=5, score_threshold=0.5)
-    
-    mock_memory_client.search.assert_called_once()
-    call_args = mock_memory_client.search.call_args[1]
-    
-    assert call_args["version"] == "v2"
-    assert "run_id" not in call_args
-    assert call_args["query"] == "test query"
-    assert call_args["limit"] == 5
-    
-    assert len(results) == 1
-    assert results[0]["content"] == "Result 1"
-
-
-@pytest.mark.v2_api
-def test_search_method_with_run_id(mem0_storage_with_run_id):
-    """Test search method with run_id"""
-    mem0_storage, mock_memory_client = mem0_storage_with_run_id
-    mock_results = {"results": [{"score": 0.9, "content": "Result 1"}, {"score": 0.4, "content": "Result 2"}]}
-    mock_memory_client.search = MagicMock(return_value=mock_results)
-    
-    results = mem0_storage.search("test query", limit=5, score_threshold=0.5)
-    
-    mock_memory_client.search.assert_called_once()
-    call_args = mock_memory_client.search.call_args[1]
-    
-    assert call_args["version"] == "v2"
-    assert call_args["run_id"] == "test-session-123"
-    assert call_args["query"] == "test query"
-    assert call_args["limit"] == 5
-    
-    assert len(results) == 1
-    assert results[0]["content"] == "Result 1"
-
-
-@pytest.mark.v2_api
-def test_search_method_with_different_result_formats(mem0_storage_with_v2_api):
-    """Test search method with different result formats"""
-    mem0_storage, mock_memory_client = mem0_storage_with_v2_api
-    
-    mock_results_dict = {"results": [{"score": 0.9, "content": "Result 1"}, {"score": 0.4, "content": "Result 2"}]}
-    mock_memory_client.search = MagicMock(return_value=mock_results_dict)
-    
-    results = mem0_storage.search("test query", limit=5, score_threshold=0.5)
-    assert len(results) == 1
-    assert results[0]["content"] == "Result 1"
-    
-    mock_results_list = [{"score": 0.9, "content": "Result 3"}, {"score": 0.4, "content": "Result 4"}]
-    mock_memory_client.search = MagicMock(return_value=mock_results_list)
-    
-    results = mem0_storage.search("test query", limit=5, score_threshold=0.5)
-    assert len(results) == 1
-    assert results[0]["content"] == "Result 3"
-    
-    mock_memory_client.search = MagicMock(return_value="unexpected format")
-    
-    results = mem0_storage.search("test query", limit=5, score_threshold=0.5)
-    assert len(results) == 0
-
-
-@pytest.mark.parametrize("run_id", [None, "", "test-123", "a" * 256])
-@pytest.mark.v2_api
-def test_run_id_edge_cases(mock_mem0_memory_client, run_id):
-    """Test edge cases for run_id parameter"""
-    with patch.object(MemoryClient, "__new__", return_value=mock_mem0_memory_client):
-        crew = MockCrew(
-            memory_config={
-                "provider": "mem0",
-                "config": {
-                    "user_id": "test_user",
-                    "api_key": "ABCDEFGH",
-                    "version": "v2",
-                    "run_id": run_id,
-                },
-            }
-        )
-        
-        if run_id == "":
-            mem0_storage = Mem0Storage(type="short_term", crew=crew)
-            assert mem0_storage.run_id == ""
-            
-            mock_mem0_memory_client.add = MagicMock()
-            mem0_storage.save("test", {})
-            assert "run_id" not in mock_mem0_memory_client.add.call_args[1]
-        else:
-            mem0_storage = Mem0Storage(type="short_term", crew=crew)
-            assert mem0_storage.run_id == run_id
-            
-            if run_id is not None:
-                mock_mem0_memory_client.add = MagicMock()
-                mem0_storage.save("test", {})
-                assert mock_mem0_memory_client.add.call_args[1].get("run_id") == run_id
-
-
-def test_invalid_version_handling(mock_mem0_memory_client):
-    """Test handling of invalid version"""
-    with patch.object(MemoryClient, "__new__", return_value=mock_mem0_memory_client):
-        crew = MockCrew(
-            memory_config={
-                "provider": "mem0",
-                "config": {
-                    "user_id": "test_user",
-                    "api_key": "ABCDEFGH",
-                    "version": "invalid",
-                },
-            }
-        )
-        
-        with pytest.raises(ValueError, match="Unsupported version"):
-            Mem0Storage(type="short_term", crew=crew)
-
-
-def test_invalid_run_id_type(mock_mem0_memory_client):
-    """Test handling of invalid run_id type"""
-    with patch.object(MemoryClient, "__new__", return_value=mock_mem0_memory_client):
-        crew = MockCrew(
-            memory_config={
-                "provider": "mem0",
-                "config": {
-                    "user_id": "test_user",
-                    "api_key": "ABCDEFGH",
-                    "version": "v2",
-                    "run_id": 123,  # Not a string
-                },
-            }
-        )
-        
-        with pytest.raises(ValueError, match="run_id must be a string"):
-            Mem0Storage(type="short_term", crew=crew)

uv.lock

@@ -738,7 +738,7 @@ wheels = [
 
 [[package]]
 name = "crewai"
-version = "0.118.0"
+version = "0.119.0"
 source = { editable = "." }
 dependencies = [
     { name = "appdirs" },
@@ -828,7 +828,7 @@ requires-dist = [
     { name = "blinker", specifier = ">=1.9.0" },
     { name = "chromadb", specifier = ">=0.5.23" },
     { name = "click", specifier = ">=8.1.7" },
-    { name = "crewai-tools", marker = "extra == 'tools'", specifier = "~=0.42.2" },
+    { name = "crewai-tools", marker = "extra == 'tools'", specifier = "~=0.44.0" },
     { name = "docling", marker = "extra == 'docling'", specifier = ">=2.12.0" },
     { name = "fastembed", marker = "extra == 'fastembed'", specifier = ">=0.4.1" },
     { name = "instructor", specifier = ">=1.3.3" },
@@ -879,7 +879,7 @@ dev = [
 
 [[package]]
 name = "crewai-tools"
-version = "0.42.2"
+version = "0.44.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "chromadb" },
@@ -894,9 +894,9 @@ dependencies = [
     { name = "pytube" },
     { name = "requests" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/17/34/9e63e2db53d8f5c30353f271a3240687a48e55204bbd176a057c0b7658c8/crewai_tools-0.42.2.tar.gz", hash = "sha256:69365ffb168cccfea970e09b308905aa5007cfec60024d731ffac1362a0153c0", size = 754967 }
+sdist = { url = "https://files.pythonhosted.org/packages/b8/1f/2977dc72628c1225bf5788ae22a65e5a53df384d19b197646d2c4760684e/crewai_tools-0.44.0.tar.gz", hash = "sha256:44e0c26079396503a326efdd9ff34bf369d410cbf95c362cc523db65b18f3c3a", size = 892004 }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/4e/43/0f70b95350084e5cb1e1d74e9acb9e18a89ba675b1d579c787c2662baba7/crewai_tools-0.42.2-py3-none-any.whl", hash = "sha256:13727fb68f0efefd21edeb281be3d66ff2f5a3b5029d4e6adef388b11fd5846a", size = 583933 },
+    { url = "https://files.pythonhosted.org/packages/ba/80/b91aa837d06edbb472445ea3c92d7619518894fd3049d480e5fffbf0c21b/crewai_tools-0.44.0-py3-none-any.whl", hash = "sha256:119e2365fe66ee16e18a5e8e222994b19f76bafcc8c1bb87f61609c1e39b2463", size = 583462 },
 ]
 
 [[package]]