diff --git a/scalable_sync.py b/scalable_sync.py
index 7fb3f45..f0a7fb2 100644
--- a/scalable_sync.py
+++ b/scalable_sync.py
@@ -366,6 +366,9 @@ def sync_once(dry_run=False):
                 continue
 
             activities = map_to_wealthfolio(summary)
+            if activities:
+                all_activities.extend(activities)
+                mark_imported(...)
             if not activities:
                 stats["dead_letter"] += 1
                 continue
@@ -385,7 +388,8 @@ def sync_once(dry_run=False):
                 except Exception as e:
                     log.error("Import failed %s: %s", tx_id, e)
                     stats["error"] += 1
-
+        if all_activities and not dry_run:
+            mcp.record_activities(all_activities)
         if not cursor or not items:
             break