Skip to content

Commit 9420149

Browse files
authored
fixed save method, changed the test cases (#3187)
* fixed save method, changed the test cases * Linting fixed
1 parent 2ab79a7 commit 9420149

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

src/crewai/memory/storage/mem0_storage.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@ def _sanitize_role(self, role: str) -> str:
6464
def save(self, value: Any, metadata: Dict[str, Any]) -> None:
6565
user_id = self._get_user_id()
6666
agent_name = self._get_agent_name()
67+
assistant_message = [{"role" : "assistant","content" : value}]
6768
params = None
6869
if self.memory_type == "short_term":
6970
params = {
@@ -93,7 +94,8 @@ def save(self, value: Any, metadata: Dict[str, Any]) -> None:
9394
if params:
9495
if isinstance(self.memory, MemoryClient):
9596
params["output_format"] = "v1.1"
96-
self.memory.add(value, **params)
97+
98+
self.memory.add(assistant_message, **params)
9799

98100
def search(
99101
self,

tests/storage/test_mem0_storage.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,10 @@
1-
import os
21
from unittest.mock import MagicMock, patch
32

43
import pytest
54
from mem0.client.main import MemoryClient
65
from mem0.memory.main import Memory
76

8-
from crewai.agent import Agent
9-
from crewai.crew import Crew
107
from crewai.memory.storage.mem0_storage import Mem0Storage
11-
from crewai.task import Task
128

139

1410
# Define the class (if not already defined)
@@ -172,7 +168,7 @@ def test_save_method_with_memory_oss(mem0_storage_with_mocked_config):
172168
mem0_storage.save(test_value, test_metadata)
173169

174170
mem0_storage.memory.add.assert_called_once_with(
175-
test_value,
171+
[{'role': 'assistant' , 'content': test_value}],
176172
agent_id="Test_Agent",
177173
infer=False,
178174
metadata={"type": "short_term", "key": "value"},
@@ -191,7 +187,7 @@ def test_save_method_with_memory_client(mem0_storage_with_memory_client_using_co
191187
mem0_storage.save(test_value, test_metadata)
192188

193189
mem0_storage.memory.add.assert_called_once_with(
194-
test_value,
190+
[{'role': 'assistant' , 'content': test_value}],
195191
agent_id="Test_Agent",
196192
infer=False,
197193
metadata={"type": "short_term", "key": "value"},

0 commit comments

Comments
 (0)