fix: deduplicate imported event ids for open data sources

2026-02-15 15:49:42 +01:00 · 2026-02-15 15:49:42 +01:00 · 9b3fe95683
commit 9b3fe95683
parent a50d51b3b1
2 changed files with 4 additions and 1 deletions
--- a/backend/open_data_connector.py
+++ b/backend/open_data_connector.py
@ -160,10 +160,14 @@ def import_event_rows(rows: list[dict], source_name: str, notes: str) -> dict:
    imported_at = now_iso()

    db_rows = []
+    seen_ids = set()
    for item in rows:
        event_type = item.get("event_type")
        if event_type not in VALID_TYPES:
            continue
+        if item["id"] in seen_ids:
+            continue
+        seen_ids.add(item["id"])

        db_rows.append(
            (