From 60c070e07714fb6d601c441224666ff4e30da3cc Mon Sep 17 00:00:00 2001
From: parshvadaftari <daftariparshva@gmail.com>
Date: Sat, 30 Aug 2025 02:27:36 +0530
Subject: [PATCH] update mem0 integration for reduced latency and better
 performance

---
 src/pipecat/services/mem0/memory.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/pipecat/services/mem0/memory.py b/src/pipecat/services/mem0/memory.py
index 629d626be..b134f5162 100644
--- a/src/pipecat/services/mem0/memory.py
+++ b/src/pipecat/services/mem0/memory.py
@@ -120,6 +120,7 @@ class Mem0MemoryService(FrameProcessor):
         try:
             logger.debug(f"Storing {len(messages)} messages in Mem0")
             params = {
+                "async_mode": True,
                 "messages": messages,
                 "metadata": {"platform": "pipecat"},
                 "output_format": "v1.1",
@@ -163,7 +164,7 @@ class Mem0MemoryService(FrameProcessor):
                     ("run_id", self.run_id),
                 ]
                 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(
                     query=query,
                     filters=filters,