wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #2541 from parshvadaftari/user/parshva/update_mem0

Browse Source 
Update mem0 integration
This commit is contained in:
Mark Backman
2025-08-30 05:11:31 -07:00
committed by GitHub
parent 93a8ea3cb2 60c070e077
commit 7cf099eae7
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/pipecat/services/mem0/memory.py
View File

@@ -120,6 +120,7 @@ class Mem0MemoryService(FrameProcessor):
try: try:
logger.debug(f"Storing {len(messages)} messages in Mem0") logger.debug(f"Storing {len(messages)} messages in Mem0")
params = { params = {
"async_mode": True,
"messages": messages, "messages": messages,
"metadata": {"platform": "pipecat"}, "metadata": {"platform": "pipecat"},
"output_format": "v1.1", "output_format": "v1.1",
@@ -163,7 +164,7 @@ class Mem0MemoryService(FrameProcessor):
("run_id", self.run_id), ("run_id", self.run_id),
] ]
clauses = [{name: value} for name, value in id_pairs if value is not None] clauses = [{name: value} for name, value in id_pairs if value is not None]
filters = {"AND": clauses} if clauses else {} filters = {"OR": clauses} if clauses else {}
results = self.memory_client.search( results = self.memory_client.search(
query=query, query=query,
filters=filters, filters=filters,