Enable deduplication for trailing extraction indexing (#173)

Author: abrookins

agent_memory_server/long_term_memory.py

@@ -393,7 +393,10 @@ async def run_delayed_extraction(
 
         # Index the extracted memories
         if extracted_memories:
-            await index_long_term_memories(extracted_memories)
+            await index_long_term_memories(
+                extracted_memories,
+                deduplicate=True,
+            )
             logger.info(
                 f"Trailing extraction completed for session {session_id}: "
                 f"{len(extracted_memories)} memories extracted and indexed"

tests/test_extraction_logic_fix.py

@@ -198,6 +198,7 @@ async def test_run_delayed_extraction_extracts_and_indexes(
                 indexed_memories = mock_index.call_args[0][0]
                 assert len(indexed_memories) == 1
                 assert indexed_memories[0].id == "extracted-1"
+                assert mock_index.call_args.kwargs.get("deduplicate") is True
 
                 # Verify working memory was updated - messages marked as extracted
                 updated_wm = await get_working_memory(