From dd69b421e30479f2d2b6bffc07e6e78ec567d9ce Mon Sep 17 00:00:00 2001 From: Lukas Pierchalla Date: Sun, 20 Sep 2026 12:52:50 +0200 Subject: [PATCH] update scalable_sync.py to extend activity recording logic and handle imported activities --- scalable_sync.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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