update scalable_sync.py to extend activity recording logic and handle imported activities

2026-09-20 12:52:50 +02:00
parent 5fd5a67995
commit dd69b421e3
1 changed files with 5 additions and 1 deletions
@@ -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