diff --git a/broker_sync/sinks/wealthfolio.py b/broker_sync/sinks/wealthfolio.py
index 51a2d41..f459952 100644
--- a/broker_sync/sinks/wealthfolio.py
+++ b/broker_sync/sinks/wealthfolio.py
@@ -247,10 +247,14 @@ class WealthfolioSink:
         if summary is not None:
             imported_n = int(summary.get("imported", 0))
             total_n = int(summary.get("total", len(valid_rows)))
-            if imported_n < total_n:
+            dupes = int(summary.get("duplicates", 0))
+            skipped = int(summary.get("skipped", 0))
+            # Duplicates are expected on every re-run (the cron re-processes the
+            # full IMAP window each night) — treat (imported + duplicates) as
+            # accounted-for. Only fail if something was genuinely lost.
+            accounted = imported_n + dupes
+            if accounted < total_n:
                 err_msg = summary.get("errorMessage") or "no errorMessage"
-                skipped = int(summary.get("skipped", 0))
-                dupes = int(summary.get("duplicates", 0))
                 raise ImportValidationError(f"Wealthfolio /import persisted {imported_n}/{total_n} "
                                             f"(skipped={skipped} duplicates={dupes}). "
                                             f"errorMessage: {err_msg}")