Resolving comments

Author: Aayush Kataria

README.md

@@ -209,7 +209,7 @@ high_conf_facts = memory.get_memories(user_id="u1", memory_type="fact", min_conf
 
 `reconcile_memories(user_id, n=50)` collapses paraphrased duplicates and resolves semantic contradictions in a single LLM pass over the N most-recent active facts. Both outcomes soft-delete the loser with a `supersede_reason` of `"duplicate"` or `"contradiction"`. See [Docs/concepts.md](Docs/concepts.md#memory-reconciliation) for details.
 
-> **Cost note.** Each reconciliation makes one LLM call covering up to `n` facts (default 50, hard cap 500). With auto-trigger, this fires every `FACT_EXTRACTION_EVERY_N × DEDUP_EVERY_N` turns per user. The previous cosine-cluster pre-filter was removed deliberately — it could not catch semantic contradictions like "vegetarian" vs "ribeye steak" — so the LLM is now invoked whenever there are ≥ 2 active facts. Tune `DEDUP_EVERY_N` upward (or override `n` per call) if you need to bound LLM cost more tightly.
+> **Cost note.** Each reconciliation makes one LLM call covering up to `n` facts (default 50, hard cap 500). With auto-trigger, this fires every `FACT_EXTRACTION_EVERY_N × DEDUP_EVERY_N` turns per user, with `n` taken from `DEDUP_POOL_SIZE`. The previous cosine-cluster pre-filter was removed deliberately — it could not catch semantic contradictions like "vegetarian" vs "ribeye steak" — so the LLM is now invoked whenever there are ≥ 2 active facts. Tune `DEDUP_EVERY_N` upward (frequency) or `DEDUP_POOL_SIZE` downward (pool size; or override `n` per call when invoking `reconcile()` directly) to bound LLM cost more tightly.
 
 | New `MemoryRecord` field | Meaning |
 |---|---|
@@ -226,6 +226,7 @@ By default, the **InProcess processor** runs each pipeline step independently as
 |---|---|---|---|
 | `FACT_EXTRACTION_EVERY_N` | `1` (every turn) | `process_extract_memories` | scheduled via `asyncio.create_task` |
 | `DEDUP_EVERY_N` | `5` | `process_reconcile` (fires every Nth extract → effectively every `FACT_EXTRACTION_EVERY_N × DEDUP_EVERY_N` turns) | scheduled via `asyncio.create_task` |
+| `DEDUP_POOL_SIZE` | `50` | pool size (`n`) passed to `process_reconcile` from the auto-trigger; hard-capped at `500` | n/a (per-call) |
 | `THREAD_SUMMARY_EVERY_N` | `10` | `process_thread_summary` | scheduled via `asyncio.create_task` |
 | `USER_SUMMARY_EVERY_N` | `20` | `process_user_summary` | scheduled via `asyncio.create_task` |
 

agent_memory_toolkit/aio/cosmos_memory_client.py

@@ -1553,6 +1553,7 @@ async def _run_auto_trigger_steps(
             thread_counter_id,
             user_counter_id,
         )
+        from ..thresholds import get_dedup_pool_size
 
         user_batch_counts: dict[str, int] = {}
 
@@ -1607,7 +1608,7 @@ async def _run_auto_trigger_steps(
 
             if fire_dedup:
                 try:
-                    await processor.process_reconcile(user_id=user_id)
+                    await processor.process_reconcile(user_id=user_id, n=get_dedup_pool_size())
                 except Exception as exc:
                     logger.warning(
                         "Auto-trigger process_reconcile failed for %s: %s",

agent_memory_toolkit/cosmos_memory_client.py

@@ -695,6 +695,7 @@ def _maybe_auto_trigger(self, turn_counts: dict[tuple[str, str], int]) -> None:
             PROCESSOR_OWNER_DURABLE,
             PROCESSOR_OWNER_INPROCESS,
             get_dedup_every_n,
+            get_dedup_pool_size,
             get_fact_extraction_every_n,
             get_processor_owner,
             get_thread_summary_every_n,
@@ -802,7 +803,7 @@ def _maybe_auto_trigger(self, turn_counts: dict[tuple[str, str], int]) -> None:
 
             if fire_dedup:
                 try:
-                    processor.process_reconcile(user_id=user_id)
+                    processor.process_reconcile(user_id=user_id, n=get_dedup_pool_size())
                 except Exception as exc:
                     logger.warning(
                         "Auto-trigger process_reconcile failed for %s: %s",